Người dùng không đồng bộ và sử dụng TransactionScope

Question

Tôi đang sử dụng IBM.XMS lib để nói chuyện với WebSphereMQ.

Khi nhận tin nhắn bằng cách sử dụng phương pháp đồng bộ, ví dụ:

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

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

Nhưng nếu tôi muốn sử dụng phương pháp đồng bộ:

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

Tôi không thể làm việc ra làm thế nào để quấn MessageListener callback trong một số TransactionScope.

Có ai biết cách thực hiện việc này không?

Answer 1

Trình nghe tin nhắn aka Không đồng bộ người tiêu dùng không thể được sử dụng trong một TransactionScope khi trình nghe tin nhắn chạy trên một chủ đề khác với chuỗi tạo ra TransactionScope. Bạn chỉ có thể sử dụng tính năng Nhận/Gửi đồng bộ bên trong một số TransactionScope.

Điều này link cho biết "Giao dịch XA không được hỗ trợ trong người tiêu dùng không đồng bộ".

Answer 2

Cũng có thể đáng giá khi bạn điều tra bằng cách sử dụng DependentClone để tạo một DependentTransaction.

"Giao dịch phụ thuộc là giao dịch mà kết quả của nó phụ thuộc vào kết quả của giao dịch mà từ đó nó được nhân bản."

"DependentTransaction là bản sao của đối tượng Transaction được tạo bằng phương thức DependentClone. Mục đích duy nhất của nó là cho phép ứng dụng đến nghỉ ngơi và đảm bảo rằng giao dịch không thể thực hiện trong khi công việc vẫn đang được thực hiện trên giao dịch (đối với ví dụ, trên một chuỗi công nhân). "

Chỉnh sửa: Chỉ cần phát hiện này trong liên quan SO danh sách câu hỏi: related question and answer thấy liên kết MSDN họ cung cấp: cũng có giá trị một đọc Managing Concurrency with DependentTransaction

Taken từ liên kết MSDN trên (cho ngắn gọn):

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(); 
}