diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-20 14:43:49 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-20 14:43:49 +0000 |
| commit | 5fd5dc40a1e1f4176f13cf568c3fa0caaece1cc7 (patch) | |
| tree | b98d51ca495ce950ebce1792b087c2114f03b8c0 /src/rabbit_variable_queue.erl | |
| parent | a16a2983598bf823ef1aaa045a9f5134997948a0 (diff) | |
| download | rabbitmq-server-5fd5dc40a1e1f4176f13cf568c3fa0caaece1cc7.tar.gz | |
amqqueue_process shouldn't confirm when a message is basic.got (it's the BQ's problem)
Diffstat (limited to 'src/rabbit_variable_queue.erl')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 565c61e7..85216dfc 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1404,6 +1404,8 @@ msgs_confirmed(GuidSet, State) -> {gb_sets:to_list(GuidSet), remove_confirms(GuidSet, State)}. msgs_written_to_disk(QPid, GuidSet) -> + io:format("variable queue notified of msgs written to disk: ~p~n", + [gb_sets:size(GuidSet)]), rabbit_amqqueue:maybe_run_queue_via_backing_queue_async( QPid, fun (State = #vqstate { msgs_on_disk = MOD, msg_indices_on_disk = MIOD, @@ -1416,6 +1418,8 @@ msgs_written_to_disk(QPid, GuidSet) -> end). msg_indices_written_to_disk(QPid, GuidSet) -> + io:format("variable queue notified of msg idx written to disk: ~p~n", + [gb_sets:size(GuidSet)]), rabbit_amqqueue:maybe_run_queue_via_backing_queue_async( QPid, fun (State = #vqstate { msgs_on_disk = MOD, msg_indices_on_disk = MIOD, |