捕获 mqrc 2009 和 2059 错误的 java 代码

Question

在我下面的代码中，connect() 方法能够捕获 2009 和 2059 异常。但是，当我关闭队列管理器或连接以在 getMessage() 方法中生成 2009 或 2059 MQ 异常时，程序挂起或没有抛出它。 它正在排队等候queue.get(retrievedMessage, getOptions);。

如果连接或队列管理器损坏，我们是否需要添加额外的打开选项以使代码知道？

连接（）
{

MQEnvironment.hostname = 主机名；
MQEnvironment.channel = 通道名称；
MQEnvironment.port = 端口名称；
        尝试
        {
        qMgr = 新 MQQueueManager(EvtqManager); // 定义一个队列管理器对象
        LOGGER.debug("队列管理器 " +EvtqManager+ " 实例初始化");
        int openOptions = MQC.MQOO_INQUIRE + MQC.MQOO_FAIL_IF_QUIESCING+ MQC.MQOO_INPUT_SHARED；
        queue = qMgr.accessQueue(queueName, openOptions, null,null,null);
        LOGGER.debug("IBM MQQueue:"+queueName+"被访问");
        getOptions = 新 MQGetMessageOptions();
        getOptions.options = MQC.MQGMO_NO_WAIT；
        获取消息（）；
        }
        抓住（）{
                    如果（MQex.reasonCode==2009 || MQex.reasonCode==2059）{
             关闭（）;
             连接（）;
        }
}

getMessage(){
    MQMessage 检索消息；
    而（真）{
               尝试 {
                检索消息 = 新 MQMessage();
                queue.get(retrivedMessage, getOptions);
                PCFMessage pcfMessage = new PCFMessage(retrivedMessage);
               }
              捕捉（MQException MQex）{
                如果（MQex.reasonCode==2009 || MQex.reasonCode==2059）{
                关闭（）;
                连接（）;
              }
             }
    }

`

Answer 1

不需要其他选项。如果 MQ 方法调用正在进行并且与队列管理器的连接中断，则该方法将返回原因代码 2009 或其他与连接错误相关的原因代码。返回的原因码取决于连接是如何断开的，例如，如果队列管理器正在关闭，则将返回 MQRC_Q_MGR_QUIESCING/MQRC_Q_QMGR_STOPPING。

挂起可能是由于检测套接字故障所花费的时间。因此，您可能需要检查呼叫等待多长时间。

MQRC 2059 在连接到队列管理器时返回，但在接收消息时不返回。所以你可以去掉 2059 的支票。

我只是对你的代码有点困惑。您在 Connect 和 getMessage 方法中调用了 shutdown() 和 Connect()。你不认为这会导致递归吗？