c# - 异步消费者和 TransactionScope 的使用

Question

我正在使用 IBM.XMS lib与 WebSphereMQ 对话。

当使用同步方式接收消息时，例如:

using (var scope = new TransactionScope(TransactionScopeOption.Required, transactionOptions))
{
       message = consumer.Receive(1000);

       if (message != null)
       {
            //Do work here
            scope.Complete();
       }
}

但是如果我想使用异步方法:

consumer.MessageListener = delegate(IMessage msg)
{
    //Do work here
    //But where do I put TransactionScope?
};

我不知道如何将 MessageListener 回调包装在 TransactionScope 中。

有人知道怎么做吗？

Answer 1

不能在 TransactionScope 中使用消息监听器 a.k.a 异步消费者，因为消息监听器运行在与创建 TransactionScope 的线程不同的线程上。您只能在 TransactionScope 中使用同步接收/发送。

这link说“异步消费者不支持 XA 事务。”