diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-08-28 15:22:59 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-08-28 15:22:59 +0100 |
| commit | 2391849dacc3ca253502f7afe4a2fe341a46266c (patch) | |
| tree | 3d0f96acc4bedf3294d3cb046a6f1535af8b71da /src | |
| parent | c3638834b1d6b4bd706686860b1dcde6af54a954 (diff) | |
| download | rabbitmq-server-git-2391849dacc3ca253502f7afe4a2fe341a46266c.tar.gz | |
minor refactorings
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 45f311f752..5789b1059c 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -121,7 +121,6 @@ init(Q = #amqqueue { name = QName, durable = Durable }) -> terminate(_Reason, State) -> %% FIXME: How do we cancel active subscriptions? State1 = stop_memory_timer(State), - QName = qname(State1), %% Delete from disk queue first. If we crash at this point, when a %% durable queue, we will be recreated at startup, possibly with %% partial content. The alternative is much worse however - if we @@ -129,7 +128,7 @@ terminate(_Reason, State) -> %% the disk_queue delete and a new queue with the same name being %% created and published to. {ok, _MS} = rabbit_mixed_queue:delete_queue(State1 #q.mixed_state), - ok = rabbit_amqqueue:internal_delete(QName). + ok = rabbit_amqqueue:internal_delete(qname(State1)). code_change(_OldVsn, State, _Extra) -> {ok, State}. |