summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorRob Harrop <rob@rabbitmq.com>2011-06-13 13:51:04 +0100
committerRob Harrop <rob@rabbitmq.com>2011-06-13 13:51:04 +0100
commit465c0d9c41cf62f2ee295d08d1829232492cd041 (patch)
tree7dfafddafa88192715e2e588480321ac4c3b1b4c /src
parent9aae97b137bb3e5e7f98f0b59c41061577f39fdd (diff)
downloadrabbitmq-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.erl7
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;