diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2011-06-13 13:51:04 +0100 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2011-06-13 13:51:04 +0100 |
| commit | 465c0d9c41cf62f2ee295d08d1829232492cd041 (patch) | |
| tree | 7dfafddafa88192715e2e588480321ac4c3b1b4c /src | |
| parent | 9aae97b137bb3e5e7f98f0b59c41061577f39fdd (diff) | |
| download | rabbitmq-server-git-465c0d9c41cf62f2ee295d08d1829232492cd041.tar.gz | |
Removed PD hack and be happy with the death reason we have
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 8f6cea3cf0..1c3277d6e4 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -121,11 +121,7 @@ terminate(shutdown = R, State = #q{backing_queue = BQ}) -> terminate({shutdown, _} = R, State = #q{backing_queue = BQ}) -> terminate_shutdown(fun (BQS) -> BQ:terminate(R, BQS) end, State); terminate(Reason, State = #q{backing_queue = BQ}) -> - DeathReason = case get(death_reason) of - undefined -> queue_deleted; - DR -> DR - end, - State1 = maybe_dead_letter_queue(DeathReason, State), + State1 = maybe_dead_letter_queue(queue_deleted, State), %% FIXME: How do we cancel active subscriptions? terminate_shutdown(fun (BQS) -> @@ -1236,7 +1232,6 @@ handle_cast({set_maximum_since_use, Age}, State) -> handle_cast(maybe_expire, State) -> case is_unused(State) of true -> ?LOGDEBUG("Queue lease expired for ~p~n", [State#q.q]), - put(death_reason, queue_expired), {stop, normal, State}; false -> noreply(ensure_expiry_timer(State)) end; |
