異步消費者和使用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(); 
}