System.RAP 报告 azure service fabric 项目的属性 IStatelessServiceInstance.OpenDuration 错误警告 [关闭]

Question

我正在开发一个 Azure Service Fabric 项目，该项目使用 Apache.NMS .NET 库从 ActiveMQ 读取消息，并创建持久消费者以从 ActiveMQ 中读取特定消息。

我能够阅读该消息并且一切正常，但我收到如下警告。

'System.RAP' reported Warning for property 'IStatelessServiceInstance.OpenDuration'. The api IStatelessServiceInstance.Open on node _Node_0 is stuck.

此警告会导致服务出错，因此我需要删除该警告。

任何人为什么给我警告。

这是我如何阅读消息的快照。

try
{
    ITopic dest = AMQSession.GetTopic(TopicName);

    using (IMessageConsumer consumer = AMQSession.CreateDurableConsumer(dest, SubscriptionName, MessageSelector, false))
    {
        IMessage message;
        while ((message = consumer.Receive()) != null)
        {
            ITextMessage txtMsg = message as ITextMessage;            
        }
    }
}
catch (Exception ex)
{
    Close();
}
finally
{
    Close();
}

Answer 1

这个问题几乎可以肯定是由于您的代码可能永远阻塞造成的。具体来说，如果没有消息到达，consumer.Receive() 将永远阻塞。正如the documentation 所说：

等待消息可用并返回

此外，即使消息确实到达，while 循环也会确保包含方法永远不会返回。

我建议您在尝试使用消息时指定超时。如果超时，则Receive 将返回null，循环将被打破，代码将不再被阻塞。