root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Merge pull request #324 from rabbitmq/rabbitmq-server-1904 

channel_exchange_metrics now has one more metric: dropped unroutable messages
This commit is contained in:
Michael Klishin 2019-04-25 18:12:55 +03:00 committed by GitHub
parent 3bed6894d7 a8495e1c30
commit 8e22e0c3f4
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
deps/rabbit_common/src/rabbit_core_metrics.erl vendored
View File

@ -166,15 +166,19 @@ channel_stats(reductions, Id, Value) ->
channel_stats(exchange_stats, publish, Id, Value) ->
%% Includes delete marker
_ = ets:update_counter(channel_exchange_metrics, Id, {2, Value}, {Id, 0, 0, 0, 0}),
_ = ets:update_counter(channel_exchange_metrics, Id, {2, Value}, {Id, 0, 0, 0, 0, 0}),
ok;
channel_stats(exchange_stats, confirm, Id, Value) ->
%% Includes delete marker
_ = ets:update_counter(channel_exchange_metrics, Id, {3, Value}, {Id, 0, 0, 0, 0}),
_ = ets:update_counter(channel_exchange_metrics, Id, {3, Value}, {Id, 0, 0, 0, 0, 0}),
ok;
channel_stats(exchange_stats, return_unroutable, Id, Value) ->
%% Includes delete marker
_ = ets:update_counter(channel_exchange_metrics, Id, {4, Value}, {Id, 0, 0, 0, 0}),
_ = ets:update_counter(channel_exchange_metrics, Id, {4, Value}, {Id, 0, 0, 0, 0, 0}),
ok;
channel_stats(exchange_stats, drop_unroutable, Id, Value) ->
%% Includes delete marker
_ = ets:update_counter(channel_exchange_metrics, Id, {5, Value}, {Id, 0, 0, 0, 0, 0}),
ok;
channel_stats(queue_exchange_stats, publish, Id, Value) ->
%% Includes delete marker
@ -225,7 +229,7 @@ channel_queue_exchange_down(Id) ->
channel_exchange_down(Id) ->
%% Delete marker
ets:update_element(channel_exchange_metrics, Id, {5, 1}),
ets:update_element(channel_exchange_metrics, Id, {6, 1}),
ok.
consumer_created(ChPid, ConsumerTag, ExclusiveConsume, AckRequired, QName,