diff options
| -rw-r--r-- | include/rabbit.hrl | 2 | ||||
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/include/rabbit.hrl b/include/rabbit.hrl index b991aa7d54..1998de35b4 100644 --- a/include/rabbit.hrl +++ b/include/rabbit.hrl @@ -70,7 +70,7 @@ -record(delivery, {mandatory, immediate, txn, sender, message}). -record(amqp_error, {name, explanation, method = none}). --record(event_queue_stats, {q_pid, messages_ready, messages_unacknowledged, +-record(event_queue_stats, {qpid, messages_ready, messages_unacknowledged, consumers, memory, exclusive_consumer_pid, exclusive_consumer_tag, backing_queue_status}). diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 808e1117d1..7fa11a2663 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -540,7 +540,7 @@ maybe_emit_stats(State = #q{last_statistics_update = LastUpdate}) -> case Now - LastUpdate > ?STATISTICS_UPDATE_INTERVAL of true -> S = {queue_stats, #event_queue_stats{ - q_pid = self(), + qpid = self(), messages_ready = i(messages_ready, State), messages_unacknowledged = i(messages_unacknowledged, State), consumers = i(consumers, State), |