diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-09-25 12:45:33 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-09-25 12:45:33 +0300 |
| commit | 682393257e2d65d99edea52bbf98c9891f64e4aa (patch) | |
| tree | 69bcbba7f61bcd20ea58725c4568353dabb71d89 /src | |
| parent | f230674213807d75c9294d8bd142a5d1069d5720 (diff) | |
| parent | 4123bfad42ba632a86909192641188fe36fc1904 (diff) | |
| download | rabbitmq-server-git-682393257e2d65d99edea52bbf98c9891f64e4aa.tar.gz | |
Merge pull request #2119 from rabbitmq/queue-rate-fix
Fix regression where queue exchange rates were too high
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index b8869a23f3..8b5fe91cc9 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -2231,9 +2231,9 @@ deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ case rabbit_event:stats_level(State, #ch.stats_timer) of fine -> ?INCR_STATS(exchange_stats, XName, 1, publish), - [?INCR_STATS(queue_exchange_stats, {QName, XName}, 1, publish) || - QRef <- AllDeliveredQRefs, - {ok, QName} <- [maps:find(QRef, QNames1)]]; + [?INCR_STATS(queue_exchange_stats, + {amqqueue:get_name(Q), XName}, 1, publish) || + Q <- Qs]; _ -> ok end, |