2015-09-07 3 views
0

У меня есть вопрос. У меня есть 2 сервера, которые имеют соединение друг с другом и имеют приложения для отправки и получения сообщений в очередь JMS. Но, несмотря на все написанное здесь client for remote JMS queue Я не могу отправить сообщение с одного сервера на другой, он либо возвращается на тот же сервер, либо не отображается нигде. Вот код, который я использую, чтобы отправить сообщение, любые идеи, что я делаю неправильно ?:Отправка сообщения удаленной очереди JMS в стеклянной платке

com.sun.messaging.ConnectionFactory connFactory = new com.sun.messaging.ConnectionFactory(); 
connFactory.setProperty(ConnectionConfiguration.imqAddressList, "10.241.5.51:7676"); 
com.sun.messaging.Queue  queue = new com.sun.messaging.Queue("jms/tQueue");//(com.sun.messaging.Queue)client.lookup("jms/tQueue"); 
try (Connection connection = connFactory.createConnection(); 
     Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
     MessageProducer producer = session.createProducer(queue)) { 
     for (int i = 0; i < 5; i++) { 
     TextMessage message = session.createTextMessage("It is a message from main class " + ": " + i); 
     System.out.println("It come from main class:" + message.getText()); 
     producer.send(message); 
     } 
    } 

ответ

0

Оказывается, я потерялся в терминологии или что-то. Этот код работал, только другой сервер должен был отправлять сообщения.