diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-09-09 13:54:30 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-09-09 13:54:30 +0100 |
| commit | 518b808b0ad0d14abf1250907c04de653c0d2bfc (patch) | |
| tree | 08cc9470cfaea3ee3dd2639b436f36f84bec2103 /src | |
| parent | 52b7ca393ba86e9ccbe6ef01ac2eacd05c43b316 (diff) | |
| download | rabbitmq-server-518b808b0ad0d14abf1250907c04de653c0d2bfc.tar.gz | |
init_expires/1 before emitting stats.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 5b4f2c41..63c0b7ac 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -163,11 +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}, + State1 = init_expires(State#q{backing_queue_state = BQS}), rabbit_event:notify(queue_created, infos(?CREATION_EVENT_KEYS, State1)), emit_stats(State1), - noreply(init_expires(State1)); + noreply(State1); Q1 -> {stop, normal, {existing, Q1}, State} end. |