将消息发送到 glassfish 中的远程 JMS 队列
Sending message to Remote JMS queue in glassfish
我有一个问题。我有 2 个相互连接的服务器,并且有一个应用程序可以将消息发送和接收到 JMS 队列中。但是尽管这里写了所有内容 client for remote JMS queue 我无法将消息从一台服务器发送到另一台服务器,它要么返回到同一台服务器,要么不在任何地方显示。
这是我用来发送消息的代码,你知道我做错了什么吗?:
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);
}
}
原来我迷失了术语什么的。
该代码有效,只有另一台服务器应该在发送消息。
我有一个问题。我有 2 个相互连接的服务器,并且有一个应用程序可以将消息发送和接收到 JMS 队列中。但是尽管这里写了所有内容 client for remote JMS queue 我无法将消息从一台服务器发送到另一台服务器,它要么返回到同一台服务器,要么不在任何地方显示。 这是我用来发送消息的代码,你知道我做错了什么吗?:
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);
}
}
原来我迷失了术语什么的。 该代码有效,只有另一台服务器应该在发送消息。