summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_amqqueue_process.erl14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index 707fa68492..e31f821015 100644
--- a/src/rabbit_amqqueue_process.erl
+++ b/src/rabbit_amqqueue_process.erl
@@ -539,14 +539,14 @@ maybe_emit_stats(State = #q{last_statistics_update = LastUpdate}) ->
case timer:now_diff(Now, LastUpdate) > ?STATISTICS_UPDATE_INTERVAL of
true ->
rabbit_event:notify(#event_queue_stats{
- qpid = self(),
- messages_ready = i(messages_ready, State),
+ qpid = self(),
+ messages_ready = i(messages_ready, State),
messages_unacknowledged = i(messages_unacknowledged, State),
- consumers = i(consumers, State),
- memory = i(memory, State),
- exclusive_consumer_tag = i(exclusive_consumer_tag, State),
- exclusive_consumer_pid = i(exclusive_consumer_pid, State),
- backing_queue_status = i(backing_queue_status, State)
+ consumers = i(consumers, State),
+ memory = i(memory, State),
+ exclusive_consumer_tag = i(exclusive_consumer_tag, State),
+ exclusive_consumer_pid = i(exclusive_consumer_pid, State),
+ backing_queue_status = i(backing_queue_status, State)
}),
State#q{last_statistics_update = Now};
_ ->