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 | 5d600facd114fe48b308da3930e4ce0bb77067ec (patch) | |
| tree | 08cc9470cfaea3ee3dd2639b436f36f84bec2103 /src | |
| parent | b5fc29bcaf0236d6d9a6834275657b2a1eb0bd6a (diff) | |
| download | rabbitmq-server-git-5d600facd114fe48b308da3930e4ce0bb77067ec.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 5b4f2c413b..63c0b7ac0e 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. |