异步消费者和使用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的线程不同的线程上运行，消息侦听器（又名异步使用者）不能用于TransactionScope。您只能使用TransactionScope内的同步接收/发送。

This link says“The XA transactions are not supported in asynchronous consumers。”

Answer 2

在使用DependentClone创建DependentTransaction时，可能值得您一边调查。

“一个从属交易是一个交易，其结果取决于它被克隆的交易结果。”

“DependentTransaction是使用DependentClone方法创建的Transaction对象的一个​​克隆，它的唯一目的是允许应用程序停下来并确保事务在事务仍在执行时不能提交（for例如，在工作者线程上）。“

编辑：只是在相关的SO问题清单看准了这一点：related question and answer看看他们提供的MSDN链接：非常值得一读Managing Concurrency with DependentTransaction

从MSDN链接采取以上（为简便起见）：

public class WorkerThread 
{ 
    public void DoWork(DependentTransaction dependentTransaction) 
    { 
     Thread thread = new Thread(ThreadMethod); 
     thread.Start(dependentTransaction); 
    } 

    public void ThreadMethod(object transaction) 
    { 
     DependentTransaction dependentTransaction = transaction as DependentTransaction; 
     Debug.Assert(dependentTransaction != null); 

     try 
     { 
      using(TransactionScope ts = new TransactionScope(dependentTransaction)) 
      { 
       /* Perform transactional work here */ 
       ts.Complete(); 
      } 
     } 
     finally 
     { 
      dependentTransaction.Complete(); 
      dependentTransaction.Dispose(); 
     } 
    } 

//Client code 
using(TransactionScope scope = new TransactionScope()) 
{ 
    Transaction currentTransaction = Transaction.Current; 
    DependentTransaction dependentTransaction;  
    dependentTransaction = currentTransaction.DependentClone(DependentCloneOption.BlockCommitUntilComplete); 
    WorkerThread workerThread = new WorkerThread(); 
    workerThread.DoWork(dependentTransaction); 

    /* Do some transactional work here, then: */ 
    scope.Complete(); 
}