diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-06-08 12:24:21 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-06-08 12:24:21 +0100 |
| commit | 0f849b8497806fe72bd2b2441c2d8cdb352a91f6 (patch) | |
| tree | 08d875e2d86af7300c002ed8e54217fca188d89c | |
| parent | 658a6a9e61e723440dcd0a57884e7ce58f4a4a86 (diff) | |
| download | rabbitmq-server-git-0f849b8497806fe72bd2b2441c2d8cdb352a91f6.tar.gz | |
idiot
| -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 08736f2518..b61e450bd0 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -555,7 +555,8 @@ handle_call({deliver_immediately, Txn, Message, ChPid}, _From, State) -> handle_call({deliver, Txn, Message, ChPid}, _From, State) -> %% Synchronous, "mandatory" delivery mode - reply(deliver_or_enqueue(Txn, ChPid, Message, State)); + {Delivered, NewState} = deliver_or_enqueue(Txn, ChPid, Message, State), + reply(Delivered, NewState); handle_call({commit, Txn}, From, State) -> NewState = commit_transaction(Txn, State), |