diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 6 | ||||
| -rw-r--r-- | src/rabbit_channel.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_reader.erl | 1 |
3 files changed, 6 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 0849586294..5b4f2c413b 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -163,9 +163,11 @@ declare(Recover, From, self(), {rabbit_amqqueue, set_ram_duration_target, [self()]}), BQS = BQ:init(QName, IsDurable, Recover), + State1 = State#q{backing_queue_state = BQS}, rabbit_event:notify(queue_created, - infos(?CREATION_EVENT_KEYS, State)), - noreply(init_expires(State#q{backing_queue_state = BQS})); + infos(?CREATION_EVENT_KEYS, State1)), + emit_stats(State1), + noreply(init_expires(State1)); Q1 -> {stop, normal, {existing, Q1}, State} end. diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 174eab4002..19d855899a 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -176,6 +176,7 @@ init([Channel, ReaderPid, WriterPid, Username, VHost, CollectorPid, queue_collector_pid = CollectorPid, stats_timer = rabbit_event:init_stats_timer()}, rabbit_event:notify(channel_created, infos(?CREATION_EVENT_KEYS, State)), + internal_emit_stats(State), {ok, State, hibernate, {backoff, ?HIBERNATE_AFTER_MIN, ?HIBERNATE_AFTER_MIN, ?DESIRED_HIBERNATE}}. diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index a21961b5e0..0ddc60e8f1 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -775,6 +775,7 @@ handle_method0(#'connection.open'{virtual_host = VHostPath}, connection = NewConnection}), rabbit_event:notify(connection_created, infos(?CREATION_EVENT_KEYS, State1)), + internal_emit_stats(State1), State1; handle_method0(#'connection.close'{}, State) when ?IS_RUNNING(State) -> lists:foreach(fun rabbit_framing_channel:shutdown/1, all_channels()), |