3

我有一个 XMS MQ 客户端应用程序，它从一系列 MQ 端点提取消息。对于某些原因代码，该过程可以继续，而对于某些原因代码，它应该中止。例如MQRC_Q_MGR_NOT_AVAILABLE，一个端点的 2059 不应中止整个过程。因此，我想检查这个原因代码。

cf = factoryFactory.CreateConnectionFactory();
foreach (Endpoint e in env.GetEndpoints())
{
    Console.WriteLine("Consuming messages from endpoint {0}({1})", e.host, e.port);

    // Set the properties
    SetConnectionProperties(cf, e);

    try
    {
        ReceiveMessagesFromEndpoint(cf);
    }
    catch (XMSException ex)
    {
        Console.WriteLine("XMSException caught: {0}", ex);
        Console.WriteLine("Error Code: {0}", ex.ErrorCode);
        Console.WriteLine("Error Message: {0}", ex.Message);
    }
}

问题是 XMSException 上唯一可以检查的属性是ex.ErrorCode和ex.Message，它们分别是：

Error Code: CWSMQ0006

和

Error Message: CWSMQ0006E: An exception was received during the call to the method ConnectionFactory.CreateConnection: CompCode: 2, Reason: 2059.

我可以在消息中看到原因，但找不到检索它的方法或属性。

4

2 回答 2

2

可能有两种方法可以做到这一点

1）您可以使用 LinkedException

类似于以下内容

    try
    {
    }
    catch (XMSException e)
    {
      if(e.LinkedException!=null)
        Console.WriteLine(e.LinkedException.Message);
      else
        Console.WriteLine(e);
    }

2) 将 amqmdnet.dll 也引用到项目中并使用 MQException.Something 之类的

    try
    {
    }
    catch (XMSException e)
    {
      if(e.LinkedException!=null)
      {
        IBM.WMQ.MQException inner = (IBM.WMQ.MQException)e.LinkedException;
            Console.WriteLine("Reason:"+ inner.ReasonCode);
      }
      else
        Console.WriteLine(e);
    }
于 2019-11-20T15:23:45.737 回答
0

OP的解决方案

根据接受的答案，“工作”代码是：

cf = factoryFactory.CreateConnectionFactory();
foreach (Endpoint e in env.GetEndpoints())
{
    Console.WriteLine("Consuming messages from endpoint {0}({1})", e.host, e.port);

    // Set the properties
    SetConnectionProperties(cf, e);

    try
    {
        ReceiveMessagesFromEndpoint(cf);
    }
    catch (XMSException ex)
    {
        Console.WriteLine("XMSException caught: {0}", ex);
        Console.WriteLine("Error Code: {0}", ex.ErrorCode);
        Console.WriteLine("Error Message: {0}", ex.Message);

        if (ex.LinkedException != null && 
                IBM.XMS.MQC.MQRC_Q_MGR_NOT_AVAILABLE.ToString().Equals(ex.LinkedException.Message))

        {
            Console.WriteLine("Queue Manager on this endpoint is not available");
            Console.WriteLine("Moving onto next endpoint");
            continue;
        }
        Console.WriteLine("Unexpected Error - Aborting");
        throw;
    }
}
于 2019-11-24T07:13:26.420 回答