Пользовательский порт ActiveMQ Producer

Question

Я реализовал JMS-производителя и пользователя, которые развернуты на двух разных хостах как в DMZ. Here Я читал, как определить пользовательский хост и порт для производителя. Но я не понимаю, где я должен поставить эту линию.

Вот мой код:

Connection connection = null; 
    try{ 

     System.out.println("Connecting to "+getBrokerUrl()); 
     connection = (new ActiveMQConnectionFactory(getBrokerUrl())).createConnection(); 
     connection.start(); 

     Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
     Topic topic = session.createTopic(this.topicName); 

     TextMessage txtMsg = session.createTextMessage(); 
        txtMsg.setText(msg); 
        txtMsg.setJMSType(msgType); 

     MessageProducer producer = session.createProducer(topic); 
         producer.send(txtMsg); 

    } 
    catch(Exception e){ 
     System.out.println("Error: " + e.getMessage()); 
    } 
    finally{ 
     try{ 
      connection.close(); 
     } 
     catch(JMSException je){ 
      System.out.println("Unable to close connection: "+je.getMessage()); 
     } 
    } 

Может кто-нибудь мне помочь?

Answer 1

Должно быть в ActiveMQConnectionFactory инстанции, вы передаете результат getBrokerUrl():

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost");