java在Websphere MQ临时队列上未收到回复

Question

我正在使用WebSphereMQ系统的发送/接收机制

我以文本格式发送的xml应该会收到回复，但是我没有收到回复

我知道xml被“发送”了，因为“事情正在发生”在目标系统中——只是我没有收到回复。回复对我来说很重要，因为如果出现故障，它可能会包含一条错误消息

因此，我没有收到回复的原因是——我不确定我的代码或Websphere MQ配置是否存在问题

非常感谢关于我的代码的任何指针或我应该请Websphere MQ管理员查看的内容

演示接收未发生的一个小型自包含示例如下所示：

public class CustomQueueConnection {
    private MQQueueConnectionFactory connectionFactory;
    private MQQueueConnection connection;

    private void runTest() throws JMSException {
        connect();
        MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
        MQQueue queue = (MQQueue) session.createQueue("queue:///REQ_SNAPSHOT.HT");
        MQQueueSender sender = (MQQueueSender) session.createSender(queue);
        TemporaryQueue temporaryQueue = session.createTemporaryQueue();
        MQQueueReceiver receiver = (MQQueueReceiver) session.createReceiver(temporaryQueue);

        TextMessage message = session.createTextMessage(
                "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n" +
                // my well constructed xml goes here...
        );

        message.setJMSReplyTo(temporaryQueue);
        sender.send(message);
        System.out.println("Sent: " + message);
        JMSMessage receivedMessage = (JMSMessage) receiver.receive(10000);
        System.out.println("Received: " + receivedMessage);
    }

    public boolean connect() {
        boolean connected = false;
        try {
            connectionFactory = new MQQueueConnectionFactory();
            connectionFactory.setCCSID(819);
            connectionFactory.setPort(1417);
            connectionFactory.setHostName("1.2.3.4");
            connectionFactory.setQueueManager("GATE1");
            connectionFactory.setChannel("CLIENTS.CHANNEL");
            connectionFactory.setTemporaryModel("GATEWAY_MODEL_QUEUE");
            connectionFactory.setTempQPrefix("MACHINE.USER_NAME.*");
            connectionFactory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);

            connection = (MQQueueConnection) connectionFactory.createQueueConnection();
            connected = true;
        } catch (JMSException e) {
            connected = false;
        }
        return connected;
    }

    public static void main(String[] args) throws JMSException {
        new CustomQueueConnection().runTest();
    }

}

以下是输出：

Sent:
        JMS Message class: jms_text
        JMSType:         null
        JMSDeliveryMode: 2
        JMSExpiration:   0
        JMSPriority:     4
        JMSMessageID:    ID:414d512050314f47415445312020202053599032201b4d05
        JMSTimestamp:    1398680728618
        JMSCorrelationID:null
        JMSDestination:  queue:///REQ_SNAPSHOT.HT
        JMSReplyTo:      queue://GATE1/MACHINE.USER_NAME.53599032201B4E04?persistence=1
        JMSRedelivered:  false
        JMS_IBM_PutDate:20140428
        JMSXAppID:WebSphere MQ Client for Java
        JMS_IBM_PutApplType:28
        JMSXUserID:aomis
        JMS_IBM_PutTime:10252859
        JMSXDeliveryCount:0
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<esb:esbMessage xmlns:esb="http://ESBServices
        Another 557 character(s) omitted
        Received: null

（注意：收到：空）

编辑：Websphere MQ版本为6.0.25

Answer 1

解决办法是双重的

首先，连接需要在创建后立即启动

        connect();
        connection.start();

其次，消息需要与DeliveryMode.NON_PERSISTENT一起发送

Answer 2

您的代码看起来不错，消息发送成功。我想让你检查一下：

1）是否有正在运行的应用程序从REQ_快照接收消息。HT队列

2）假设有一个应用程序正在运行并接收消息，该应用程序是否成功地处理了传入的XML消息？它是否抛出任何异常

3）如果传入消息处理成功，是否将应答放入正确的应答队列“MACHINE.USER_NAME.53599032201B4E04”？检查在放置回复消息时是否遇到任何问题