Получает всегда нулевое сообщение при попытке прочитать сообщение из MQ - PullRequest
Новая
       5

Получает всегда нулевое сообщение при попытке прочитать сообщение из MQ

0 голосов
/ 04 июня 2018

Я пытаюсь получить сообщение от MQ.Я могу видеть сообщения в MQ Explorer.Но я не могу получить сообщения.Это всегда возвращает ноль.Но я могу отправить сообщение в очередь.

Код здесь. 

 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() : "";

1 Ответ

0 голосов
/ 04 июня 2018

Чтобы получить сообщение, необходимо выполнить connection.start () перед выполнением receive.receive (10000) -

...