MessageReadPropertyFilter在使用MSMQ时重置

奇怪的一个.我们有一个多线程应用程序,它从MSMQ队列中提取消息,然后根据消息执行操作.所有这些都是使用DTC完成的.

有时,由于某些原因我无法描述,我们在将消息从队列中拉出时会收到消息读取错误.

应用中使用的代码:

Message[] allMessagesOnQueue = this.messageQueue.GetAllMessages();

foreach (Message currentMessage in allMessagesOnQueue)
{
    if ((currentMessage.Body is IAMessageIDealWith))
    {
                // do something;    
    }
}

访问currentMessage.Body时,有时会抛出异常:

System.InvalidOperationException:接收消息时未检索到Property Body.确保正确设置了PropertyFilter.

现在 - 这只在某些时候发生 - 看起来好像队列中的MessageReadPropertyFilter将Body属性设置为false.

至于它是如何变得像这有点神秘.Body属性是默认值之一,我们absolutley从未明确地将其设置为false.

有没有其他人看到这种行为或有一些想法为什么这个值被设置为假？

如前所述,您可以通过属性在System.Messaging.MessagePropertyFilter对象上可以访问的对象上显式设置布尔值.messageQueueMessageReadPropertyFilter

如果您希望在收到或达到峰值时从消息中提取所有数据,请使用:

this.messageQueue.MessageReadPropertyFilter.SetAll(); // add this line
Message[] allMessagesOnQueue = this.messageQueue.GetAllMessages();
// ...

// Specify to retrieve selected properties.
MessagePropertyFilter filter= new MessagePropertyFilter();
filter.ClearAll();
filter.Body = true;
filter.Priority = true;
this.messageQueue.MessageReadPropertyFilter = filter;
Message[] allMessagesOnQueue = this.messageQueue.GetAllMessages();
// ...

this.messageQueue.MessageReadPropertyFilter.SetDefaults();