diff options
| -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), |