diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-13 16:08:19 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-13 16:08:19 +0100 |
| commit | ea9361d575c3f1ea292c1880e49fabab747e2e79 (patch) | |
| tree | d6f8c8d08d87bf087c6cfc60e17a5fef768502b7 | |
| parent | 4883ff548fb8761684177e8fc77ee212e51a3a81 (diff) | |
| download | rabbitmq-server-git-ea9361d575c3f1ea292c1880e49fabab747e2e79.tar.gz | |
puback is also sent after something basic.gets the message
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 38eedad3a3..2f03846204 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -688,6 +688,7 @@ handle_call({basic_get, ChPid, NoAck}, _From, case BQ:fetch(AckRequired, BQS) of {empty, BQS1} -> reply(empty, State1#q{backing_queue_state = BQS1}); {{Message, IsDelivered, AckTag, Remaining}, BQS1} -> + confirm_function(Message), case AckRequired of true -> C = #cr{acktags = ChAckTags} = ch_record(ChPid), store_ch_record( |