diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-02-09 13:37:21 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-02-09 13:37:21 +0000 |
| commit | 3134c266c9d8c82d2c63aab73cdc4e285d668cea (patch) | |
| tree | e684c96f679d6567f93ffed449a6a700fd2e4eae | |
| parent | cf12d1898ebdfaabfadd05723dd1528c36a31d6e (diff) | |
| download | rabbitmq-server-git-3134c266c9d8c82d2c63aab73cdc4e285d668cea.tar.gz | |
Stored the ch_pid in the txn
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 4f70019365..b6650ddd2c 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -519,7 +519,8 @@ all_tx_record() -> record_pending_message(Txn, ChPid, Message) -> Tx = #tx{pending_messages = Pending} = lookup_tx(Txn), record_current_channel_tx(ChPid, Txn), - store_tx(Txn, Tx #tx { pending_messages = [Message | Pending] }). + store_tx(Txn, Tx #tx { pending_messages = [Message | Pending], + ch_pid = ChPid }). record_pending_acks(Txn, ChPid, MsgIds) -> Tx = #tx{pending_acks = Pending} = lookup_tx(Txn), |