diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-02-20 17:23:39 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-02-20 17:23:39 +0000 |
| commit | cdfecd188e858aa7b9d4e0b00a7c67249baf1eb0 (patch) | |
| tree | 680a138a78d87d15aa94a36f388cefa02da91570 /src | |
| parent | e3bf1f0363f36719dab626b7643de187aac489fb (diff) | |
| download | rabbitmq-server-git-cdfecd188e858aa7b9d4e0b00a7c67249baf1eb0.tar.gz | |
Ahem
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 5c376681d8..78b0d23d47 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1168,7 +1168,7 @@ handle_call({basic_consume, NoAck, ChPid, Limiter, AC1 = queue:in(E, State1#q.active_consumers), run_message_queue(State1#q{active_consumers = AC1}) end, - maybe_send_drained(C1, State), + maybe_send_drained(C1, State2), emit_consumer_created(ChPid, ConsumerTag, ExclusiveConsume, not NoAck, qname(State2)), reply(ok, State2) @@ -1383,7 +1383,7 @@ handle_cast({credit, ChPid, CTag, Credit, Drain}, rabbit_channel:send_credit_reply(ChPid, BQ:len(BQS)), State1 = possibly_unblock( State, ChPid, fun(C) -> C#cr{limiter = Lim2} end), - maybe_send_drained(lookup_ch(ChPid), State), + maybe_send_drained(lookup_ch(ChPid), State1), noreply(State1); handle_cast(wake_up, State) -> |