diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-13 21:22:54 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-13 21:22:54 +0000 |
| commit | 9df36f314073d5e174b18d637399fd49587dbeec (patch) | |
| tree | e641f69e09a35bf37d5e32c7fad8ce5b69171b0d /src | |
| parent | 443d7b8806d63579364b59b2e56b58774c548179 (diff) | |
| download | rabbitmq-server-git-9df36f314073d5e174b18d637399fd49587dbeec.tar.gz | |
don't invoke run_message_queue in handle_cast/run_backing_queue
Since that would only be necessary of the BQ:invoke modified the
consumers, which it can't, or added messages to the queue, which it
shouldn't.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 00a3a85acf..4cd21c0af5 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1216,8 +1216,7 @@ handle_cast(_, State = #q{delayed_stop = DS}) when DS =/= undefined -> handle_cast({run_backing_queue, Mod, Fun}, State = #q{backing_queue = BQ, backing_queue_state = BQS}) -> - noreply(run_message_queue( - State#q{backing_queue_state = BQ:invoke(Mod, Fun, BQS)})); + noreply(State#q{backing_queue_state = BQ:invoke(Mod, Fun, BQS)}); handle_cast({deliver, Delivery = #delivery{sender = Sender}, Delivered, Flow}, State = #q{senders = Senders}) -> |