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 | f4e39903693a58872288213f06dd16ff11db0723 (patch) | |
| tree | 237d284700dbe3ebc25df5950511f33cbebf2699 /src | |
| parent | cb2bb7e6ab0458b559f2683dd65b6e81299d8ce7 (diff) | |
| download | rabbitmq-server-git-f4e39903693a58872288213f06dd16ff11db0723.tar.gz | |
Send a stats event as soon as you wake up.
Diffstat (limited to 'src')
| -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 c7c8cee3b9..cce937192f 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 4072a8df02..6a1c40a662 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}; |