在事务中接收消息
Receiving message in a transaction
我正在编写一个基本的 MSMQ 生产者和消费者,但在尝试接收消息作为事务的一部分时遇到了问题。
队列在 Windows Server 2003 机器上,它肯定设置为事务性。我的生产者能够毫无问题地将消息作为事务的一部分放入队列中。我也可以毫无问题地从队列中读取消息,只要我不在事务中这样做即可。我做错了什么?
这是我尝试使用队列的代码块:
using (MessageQueue msgQ = new MessageQueue(myQueueName))
{
try
{
using (MessageQueueTransaction msgTx = new MessageQueueTransaction())
{
msgTx.Begin();
msg = msgQ.Receive(new TimeSpan(0, 0, 0, 0, 1000), msgTx);
Console.WriteLine("Message " + msg.LookupId.ToString() + " received");
msg.Formatter = new XmlMessageFormatter(new string[] { "System.String,mscorlib" });
if (ParseMessage(msg.Body.ToString()))
{
msgTx.Commit();
Console.WriteLine("Message " + msg.LookupId.ToString() + " delivered");
}
else
{
msgTx.Abort();
Console.WriteLine("Message " + msg.LookupId.ToString() + " not delivered");
}
}
}
catch (MessageQueueException exc)
{
if (exc.MessageQueueErrorCode == MessageQueueErrorCode.IOTimeout)
Console.WriteLine("No more messages available");
else
Console.WriteLine("Unknown error encountered while receiving");
}
}
所以如果我删除 using (MessageQueueTransaction ...)
封装,一切正常,当然除了我不能 commit
或 abort
交易取决于 [= 的布尔结果14=]
不过,当我添加事务位时,只要我点击 msgQ.Receive(...)
行,我就会得到一个 MessageQueueException
。异常消息和基数为空,MessageQueueErrorCode
为 0xc00e008b
,根据 this MSDN page 转换为:
MQ_ERROR_OPERATION_NOT_SUPPORTED_BY_REMOTE_COMPUTER (0xC00E008B)
Returned when an attempt is made to receive or peek at a message using
a lookup identifier from a remote queue residing on a computer running
MSMQ 1.0 or MSMQ 2.0.
现在,据我所知,我并没有尝试根据查找标识符接收或查看另外,MSMQ 在 Windows Server 2003 上 运行,这意味着它应该无论如何都是MSMQ 3.0。
我哪里错了?
您正在执行远程事务接收。这是在 MSMQ 4.0 中引入的。将服务器升级到受支持的操作系统。
我正在编写一个基本的 MSMQ 生产者和消费者,但在尝试接收消息作为事务的一部分时遇到了问题。
队列在 Windows Server 2003 机器上,它肯定设置为事务性。我的生产者能够毫无问题地将消息作为事务的一部分放入队列中。我也可以毫无问题地从队列中读取消息,只要我不在事务中这样做即可。我做错了什么?
这是我尝试使用队列的代码块:
using (MessageQueue msgQ = new MessageQueue(myQueueName))
{
try
{
using (MessageQueueTransaction msgTx = new MessageQueueTransaction())
{
msgTx.Begin();
msg = msgQ.Receive(new TimeSpan(0, 0, 0, 0, 1000), msgTx);
Console.WriteLine("Message " + msg.LookupId.ToString() + " received");
msg.Formatter = new XmlMessageFormatter(new string[] { "System.String,mscorlib" });
if (ParseMessage(msg.Body.ToString()))
{
msgTx.Commit();
Console.WriteLine("Message " + msg.LookupId.ToString() + " delivered");
}
else
{
msgTx.Abort();
Console.WriteLine("Message " + msg.LookupId.ToString() + " not delivered");
}
}
}
catch (MessageQueueException exc)
{
if (exc.MessageQueueErrorCode == MessageQueueErrorCode.IOTimeout)
Console.WriteLine("No more messages available");
else
Console.WriteLine("Unknown error encountered while receiving");
}
}
所以如果我删除 using (MessageQueueTransaction ...)
封装,一切正常,当然除了我不能 commit
或 abort
交易取决于 [= 的布尔结果14=]
不过,当我添加事务位时,只要我点击 msgQ.Receive(...)
行,我就会得到一个 MessageQueueException
。异常消息和基数为空,MessageQueueErrorCode
为 0xc00e008b
,根据 this MSDN page 转换为:
MQ_ERROR_OPERATION_NOT_SUPPORTED_BY_REMOTE_COMPUTER (0xC00E008B)
Returned when an attempt is made to receive or peek at a message using a lookup identifier from a remote queue residing on a computer running MSMQ 1.0 or MSMQ 2.0.
现在,据我所知,我并没有尝试根据查找标识符接收或查看另外,MSMQ 在 Windows Server 2003 上 运行,这意味着它应该无论如何都是MSMQ 3.0。
我哪里错了?
您正在执行远程事务接收。这是在 MSMQ 4.0 中引入的。将服务器升级到受支持的操作系统。