diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-01-16 15:43:40 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-01-16 15:43:40 +0000 |
| commit | f92fa9559b4119937cc4dfe3ec59f19516dd8d63 (patch) | |
| tree | 5d531f5bc921ab865854c876fc2214abd5e48928 /src | |
| parent | ce346e5b75ffc3ed2ea234d04b3c3b4ed08f744a (diff) | |
| download | rabbitmq-server-git-f92fa9559b4119937cc4dfe3ec59f19516dd8d63.tar.gz | |
only monitor publishers when they publish with flow control
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 af80905bdf..b2279b3088 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1047,9 +1047,9 @@ handle_cast({run_backing_queue, Mod, Fun}, State) -> handle_cast({deliver, Delivery = #delivery{sender = Sender}, Flow}, State) -> %% Asynchronous, non-"mandatory", non-"immediate" deliver mode. - ch_record_publisher(Sender), case Flow of - flow -> credit_flow:ack(Sender); + flow -> ch_record_publisher(Sender), + credit_flow:ack(Sender); noflow -> ok end, noreply(deliver_or_enqueue(Delivery, State)); |