我正在尝试使用来自 MQ 的消息,但代码挂起并且不显示输出。
JmsFactoryFactory FF = jmsFactoryFactory.getInstance(WMQConstants.WMQ_PROVIDER);
JmsConnectionFactory cf = FF.createConnectionFactory();
cf.setStringProperty(WMQConstants.WMQ_HOST_NAME, HOST);
cf.setStringProperty(WMQConstants.WMQ_PORT, PORT);
cf.setStringProperty(WMQConstants.WMQ_CHANNEL, CHANNEL);
cf.setStringProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT);
cf.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, QMGR);
cf.setStringProperty(WMQConstants.WMQ_APPLICATIONNAME, "JMS");
Connection connection = cf.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue(queuename);
MessageConsumer consumer1 = session.createConsumer(destination);
Message reply = consumer1.receive();
System.out.println(reply);
它不显示消息并挂起,甚至不终止。
最佳答案
您需要调用start()
在您的 javax.jms.Connection
实例上,以便让消息流向消费者,例如:
connection.start()
另外,值得注意的是,调用javax.jms.MessageConsumer#receive()
预计会阻塞,直到收到消息,因此您会看到预期的行为。如果您不想屏蔽可以调用javax.jms.MessageConsumer#receive(long)
并指定超时(以毫秒为单位)。
关于java - 消费来自 MQ 的消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60676137/