diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 14 |
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}; _ -> |