尝试从 MQ 读取消息时始终收到空消息

Question

我尝试接收来自 MQ 的消息。我可以在 MQ Explorer 中看到消息。但我无法收到消息。它始终 return 为空。但是我可以将消息放到队列中。

代码在这里。

 MQQueueConnectionFactory cf = new MQQueueConnectionFactory();
    cf.setHostName("localhost");
    cf.setPort(1415);

    cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT);

    cf.setQueueManager("TEST");
    cf.setChannel("TEST.CHANNEL");


    MQQueueConnection connection = (MQQueueConnection)cf.createQueueConnection("mqusr","q@789945");

    MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    MQQueue replyQueue = (MQQueue) session.createQueue("queue:///TEST.REPLY.QUEUE");
    MQQueueReceiver receiver = (MQQueueReceiver) session.createReceiver(replyQueue);

    TextMessage receivedMessage = (TextMessage) receiver.receive(10000);
   String reponseMessage = receivedMessage != null ? receivedMessage.toString() : "";

Answer 1

要接收消息，您需要在执行 receive.receive(10000) –

之前发出 connection.start()

尝试从 MQ 读取消息时始终收到空消息

Receives always null message while trying to read a message from MQ

java

jms

ibm-mq