TransactionScope with MQ - 读写消息

TransactionScope with MQ - read and write message

我有一段 vb.net 代码可以从 MQ 队列读取消息并将其写入另一个队列。

它在事务中执行此操作 (using New TransactionScope())，因此如果写入失败，读取将被回滚。

问题是，事务似乎只有在我关闭 .net 程序后才会提交。

使用 MQ Explorer，我看到消息移动，然后它在队列状态中显示“Uncommitted Messages: Yes”（并且消息保留在新队列中），直到 .net 程序关闭 - 此时点消息被另一个程序（IIB）从队列中读取。

所以，在我看来 TransactionScope 没有被处理掉；但我想不出为什么不。

相关代码如下：

WPF 在按下按钮时调用命令，该命令调用以下方法（已简化）：

' MQMessageDetails is just a data-storage class for message data
Friend Function MoveMessages(messages as IEnumerable(of MQMessageDetails))
    For Each msg in messages
       Try
        Using ts As New TransactionScope()
            success = WriteMessage(msg, "Q.OUT")
            success = success and ReadMessage(msg)
            If success Then
                ts.Complete()
            End If
        End Using
       Catch ....
       End Try
    Next
End Function

这是我在 MQ 资源管理器中看到的内容：

**Before program start**
Q.IN - depth 2, no uncommitted messages
Q.OUT - depth 0, no uncommitted messages

**Move button clicked**
Q.IN - depth 1, 1 uncommitted message
Q.OUT - depth 1, 1 uncommitted message

**Program closed**
Q.IN - depth 1, no uncommitted messages
Q.OUT - depth 0, no uncommitted messages <- the message was read by another program

从 MQSeries 的角度来看，.NET TransactionScope 是一个外部协调的事务。 MQ只会在特定情况下参与外部协调的事务。

例如您可能会发现在客户端环境中测试时需要 MQ 提交，但在生产服务器上则不需要。

和

http://www.mqseries.net/phpBB2/viewtopic.php?t=49148

IBM 红皮书（无论日期如何）总是一本好书：

http://www.redbooks.ibm.com/redbooks/pdfs/sg247012.pdf

TransactionScope with MQ - 读写消息

TransactionScope with MQ - read and write message

vb.net

transactionscope

ibm-mq