diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-07-26 16:18:28 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-07-26 16:18:28 +0100 |
| commit | 5d520ec46e6178d6cd7df32b33aeb8bd3cb7028b (patch) | |
| tree | 237d284700dbe3ebc25df5950511f33cbebf2699 | |
| parent | 8ed9a53e3c075532be290debaf8b5d4303790bc1 (diff) | |
| download | rabbitmq-server-5d520ec46e6178d6cd7df32b33aeb8bd3cb7028b.tar.gz | |
Send a stats event as soon as you wake up.
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_channel.erl | 1 |
2 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index c7c8cee3..cce93719 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -239,6 +239,7 @@ ensure_stats_timer(State = #q{stats_level = none}) -> ensure_stats_timer(State = #q{stats_timer_ref = undefined, q = Q}) -> {ok, TRef} = timer:apply_interval(?STATS_INTERVAL, rabbit_amqqueue, emit_stats, [Q]), + emit_stats(State), State#q{stats_timer_ref = TRef}; ensure_stats_timer(State) -> State. diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 4072a8df..6a1c40a6 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -314,6 +314,7 @@ ensure_stats_timer(State = #ch{stats_level = none}) -> State; ensure_stats_timer(State = #ch{stats_timer_ref = undefined}) -> + internal_emit_stats(State), {ok, TRef} = timer:apply_interval(?STATS_INTERVAL, rabbit_channel, emit_stats, [self()]), State#ch{stats_timer_ref = TRef}; |