小编spe*_*s82的帖子

我正在连接到 IBM Websphere MQ。我希望能够将回复消息与正确的请求消息相匹配。我已经翻阅了数百页才能得到这个，但没有运气。

我有一个类 - MQHandler - 它将一条消息发送到一个定义的队列，并从另一个队列读取请求。这工作得很好，但是，如果多个用户同时使用该应用程序，消息就会混淆。

我似乎无法在接收器上找到一种方法来指示要匹配的 CorrelationID。就像是...

消费者.接收(选择器);

您可以检查以下方法以确保我正确执行此操作吗？

/**
 * When the class is called, this initialisation is done first.
 * 
 * @throws JMSException
 */
public void init() throws JMSException
{
    // Create a connection factory
    JmsFactoryFactory ff;
    try
    {
        ff = JmsFactoryFactory.getInstance( WMQConstants.WMQ_PROVIDER );
        cf = ff.createConnectionFactory();

        // Set the properties
        cf.setStringProperty( WMQConstants.WMQ_HOST_NAME, hostServer );
        cf.setIntProperty( WMQConstants.WMQ_PORT, 1414 );
        cf.setStringProperty( WMQConstants.WMQ_CHANNEL, channel );
        cf.setIntProperty( WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT );
        cf.setStringProperty( WMQConstants.WMQ_QUEUE_MANAGER, qManager );

        connection = cf.createConnection(); …