diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-11-29 12:40:52 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-11-29 12:40:52 +0000 |
| commit | 809e3999e60dd89e1e8e86a84695f45202232e11 (patch) | |
| tree | 1bdee7be039e45cbdf4e5b5fce6a3ebea3d88223 /src/rabbit_amqqueue_process.erl | |
| parent | d895717caa4cfb16a031e8d449404585950678bb (diff) | |
| download | rabbitmq-server-809e3999e60dd89e1e8e86a84695f45202232e11.tar.gz | |
Present the whole amqqueue record to the BQ (remove duplicated IsDurable flag, correct BQ callbacks)
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 2ae05300..08c688c7 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -150,8 +150,7 @@ code_change(_OldVsn, State, _Extra) -> %%---------------------------------------------------------------------------- declare(Recover, From, - State = #q{q = Q = #amqqueue{durable = IsDurable}, - backing_queue = BQ, backing_queue_state = undefined, + State = #q{q = Q, backing_queue = BQ, backing_queue_state = undefined, stats_timer = StatsTimer}) -> case rabbit_amqqueue:internal_declare(Q, Recover) of not_found -> {stop, normal, not_found, State}; @@ -162,7 +161,7 @@ declare(Recover, From, ok = rabbit_memory_monitor:register( self(), {rabbit_amqqueue, set_ram_duration_target, [self()]}), - BQS = BQ:init(Q, IsDurable, Recover), + BQS = BQ:init(Q, Recover), State1 = process_args(State#q{backing_queue_state = BQS}), rabbit_event:notify(queue_created, infos(?CREATION_EVENT_KEYS, State1)), |