1

JMS MDB に要求を送信するクライアントがあります。メッセージをMDB に送信する場合は問題なく動作しますが、MDB からクライアントに返された応答をクライアントに取得させる方法を理解することはできません。

編集: クライアント コードは、同じインスタンス上の Web サービスであり、@WebService. それが違いを生むかどうかはわかりませんが（トランザクションなど）、この1つの問題を除けばうまくいくようです。

MDB コード:

private void sendReply(String replyData, javax.jms.Message requestMessage)
{
    try
    {
        logger.info("sendReply message received had ID: " + requestMessage.getJMSMessageID());
        logger.info("sendReply message getJMSReplyTo: " + requestMessage.getJMSReplyTo());

        Session session = connection.createSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);

        final Queue replyQueue = (Queue) requestMessage.getJMSReplyTo();
        MessageProducer producer = session.createProducer(replyQueue);
        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

        TextMessage message = session.createTextMessage();
        message.setText(replyData);
        message.setJMSCorrelationID(requestMessage.getJMSMessageID());

        producer.send(message, DeliveryMode.PERSISTENT, 9, 60000);
        producer.close();

        logger.info("sendReply message returned had ID: " + message.getJMSMessageID());

        session.close();

        logger.debug("sendReply sent reply containing:\n" + replyData);
    }
    catch (Throwable e)
    {
        logger.warn("Exception in sendReply(): " + stackToString(e));
    }
}

クライアントコード:

connection = connectionFactory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(requestQueue);

Message message = null;

// Snip creation of message

producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
final Queue replyQueue = session.createTemporaryQueue();
message.setJMSReplyTo(replyQueue);
consumer = session.createConsumer(replyQueue);  
producer.send(message);
producer.close();

log.info("call message transmitted had  Message ID: " + message.getJMSMessageID());

TextMessage replyMessage = (TextMessage)consumer.receive(JMS_REPLY_TIMEOUT); // 30 seconds

log.info("call message returned had Correlation ID: " + replyMessage.getJMSCorrelationID());
log.info("call message returned had     Message ID: " + replyMessage.getJMSMessageID());

これを実行するたびに、行TextMessage replyMessage = (TextMessage)consumer.receive(JMS_REPLY_TIMEOUT);は null を返します。毎回。私は何を間違っていますか？MDB コードは正常に実行されます。ログ メッセージはすべて関連データを出力し、MDB が受信したメッセージの内容は期待どおりです。仕事に行けないのは、この返信メッセージだけです。

次のコードを使用して一時キューを参照すると、メッセージが表示されます! メッセージIDを確認すると、送信した返信メッセージは間違いなくキューに入っていますが、呼び出しconsumer.receive(JMS_REPLY_TIMEOUT)はまだnullを返します...何が起こっているのかわかりません。

log.info("Browsing Queue");
QueueBrowser browser = session.createBrowser(replyQueue);
final Enumeration<?> en = browser.getEnumeration();
while (en.hasMoreElements()) {
    Message m = (Message) en.nextElement();
    log.info("Found message in Queue with Browser with ID [{}] and CorrelID [{}]", m.getJMSMessageID(), m.getJMSCorrelationID());
}
browser.close();

Java 1.7.0_04 64ビットを搭載したUbuntu 10.04でGlassfish 3.1.2.2を実行しています。

編集:次のように、送信と受信を別々のトランザクションに分割しようとしました:

@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
private void sendMessage(final Session session, final Message message) throws JMSException {
    // Create a MessageProducer from the Session to the Topic or Queue
    final MessageProducer producer = session.createProducer(requestQueue);

    try {
        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

        producer.send(message);
    }
    finally {
        producer.close();
    }
}

@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
private TextMessage receiveMessage(Session session, Destination replyQueue) throws JMSException {
    final MessageConsumer consumer = session.createConsumer(replyQueue);
    try {
        final TextMessage m = (TextMessage)consumer.receive(JMS_REPLY_TIMEOUT);
        return m;
    }
    finally {
        consumer.close();
    }
}

それは私の問題を解決しませんでしたが、これらのメソッドに新しいトランザクションがあることを確認するために必要なことがそれだけであるかどうかはわかりません。

編集:受信方法を次のように変更しました: 

@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
private TextMessage receiveMessage(Session session, Destination replyQueue) throws JMSException {
    final MessageConsumer consumer = session.createConsumer(replyQueue);
    try {
        log.info("Receiving message on Queue [{}]", replyQueue);
        final TextMessage m = (TextMessage)consumer.receive(JMS_REPLY_TIMEOUT);
        log.info("Received message [{}]", m);
        log.info("Browsing Queue");
        QueueBrowser browser = session.createBrowser((Queue) replyQueue);
        final Enumeration<?> en = browser.getEnumeration();
        while (en.hasMoreElements()) {
            Message mess = (Message) en.nextElement();
            log.info("Found message in Queue with Browser with ID [{}] and CorrelID [{}]", mess.getJMSMessageID(), mess.getJMSCorrelationID());
        }
        browser.close();
        return m;
    }
    finally {
        consumer.close();
    }
}

そして、私が得るログ出力は次のとおりです。

20130225200939808 CLIENT heartBeat Called.
20130225200939808 CLIENT heartBeat Sending Message...
20130225200940020 CLIENT callMAPSWebServiceMDB building TextMessage
20130225200940057 CLIENT Sending message
20130225200940064 CLIENT Sent message
20130225200940067 CLIENT message transmitted had  Message ID: ID:1-192.168.2.105(b5:49:dd:bf:5b:a6)-1-1361776180058
20130225200940077 CLIENT Receiving message on Queue [Oracle GlassFish(tm) Server MQ Destination
getName():      temporary_destination://queue/192.168.2.105/3170601277394174976/1
Class:          com.sun.messaging.jms.ra.TemporaryQueue
getVERSION():       3.0
isReadonly():       false
getProperties():    {imqDestinationName=temporary_destination://queue/192.168.2.105/3170601277394174976/1, imqDestinationDescription=A Description for the Destination Object}]
20130225200940183 SERVER Message Received
20130225200940757 SERVER Function called is: [heartBeat]
20130225200950759 SERVER sendReply message received had ID: ID:1-192.168.2.105(b5:49:dd:bf:5b:a6)-1-1361776180058
20130225200950760 SERVER sendReply message getJMSReplyTo: Oracle GlassFish(tm) Server MQ Destination
getName():      temporary_destination://queue/192.168.2.105/3170601277394174976/1
Class:          com.sun.messaging.jms.ra.TemporaryQueue
getVERSION():       3.0
isReadonly():       false
getProperties():    {imqDestinationName=temporary_destination://queue/192.168.2.105/3170601277394174976/1, imqDestinationDescription=A Description for the Destination Object}
20130225200950777 SERVER Sending reply message
20130225200950779 SERVER Sent reply message
20130225200950780 SERVER sendReply message returned had ID: ID:2-192.168.2.105(b5:49:dd:bf:5b:a6)-1-1361776190777
20130225200950781 SERVER MAPSWebServiceMDB Message Done
20130225201010078 CLIENT Received message [null]
20130225201010080 CLIENT Browsing Queue
20130225201010092 CLIENT Found message in Queue with Browser with ID [ID:2-192.168.2.105(b5:49:dd:bf:5b:a6)-1-1361776190777] and CorrelID [ID:1-192.168.2.105(b5:49:dd:bf:5b:a6)-1-1361776180058]

そのため、キューで 30 秒間待機したにもかかわらず、ずっとキューにあったメッセージを受け取りませんでした。だから何かがおかしい。それは私がしていることですか？それとも Glassfish のバグですか?

4

1 に答える 1

1

追加する必要があります

connection.start();

応答を受信できるようにします。

于 2013-07-30T13:03:16.093 に答える