diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-06-09 14:11:14 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-06-09 14:11:14 +0100 |
| commit | db003d71517a2d093656517691a4bce691b086fd (patch) | |
| tree | 4ed7c7016cbbd40e71f32cf498b9b09ecdd67922 /src | |
| parent | 230a4dc9cc263d85b8bac62a475849262abf1ae1 (diff) | |
| download | rabbitmq-server-git-db003d71517a2d093656517691a4bce691b086fd.tar.gz | |
might as well do the reply first thing, before the case.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index eccd226b04..db83675738 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -717,6 +717,7 @@ handle_call(purge, _From, State = #q{backing_queue = BQ, reply({ok, Count}, State#q{backing_queue_state = BQS1}); handle_call({requeue, AckTags, ChPid}, From, State) -> + gen_server2:reply(From, ok), case lookup_ch(ChPid) of not_found -> rabbit_log:warning("Ignoring requeue from unknown ch: ~p~n", @@ -725,7 +726,6 @@ handle_call({requeue, AckTags, ChPid}, From, State) -> C = #cr{acktags = ChAckTags} -> ChAckTags1 = subtract_acks(ChAckTags, AckTags), store_ch_record(C#cr{acktags = ChAckTags1}), - gen_server2:reply(From, ok), noreply(requeue_and_run(AckTags, State)) end; |