diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-04-27 05:42:07 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-04-27 05:42:07 +0100 |
| commit | 9f619c31bafe8726d13f810d34738d54a1805cfe (patch) | |
| tree | 257defd22298ca65fd587018a7efca10296ae335 | |
| parent | 9adca0465222f0b90b129daf9a505a24b30c394b (diff) | |
| download | rabbitmq-server-git-9f619c31bafe8726d13f810d34738d54a1805cfe.tar.gz | |
explode on attempted double initialisation of queue
which inidicates a serious bug and thus we shouldn't ignore it
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 3b5bd82371..2eaf8b7e29 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -729,9 +729,6 @@ handle_cast({init, Recover}, self(), {rabbit_amqqueue, set_ram_duration_target, [self()]}), noreply(State#q{backing_queue_state = BQ:init(QName, IsDurable, Recover)}); -handle_cast({init, _Recover}, State) -> - noreply(State); - handle_cast({deliver, Txn, Message, ChPid}, State) -> %% Asynchronous, non-"mandatory", non-"immediate" deliver mode. {_Delivered, NewState} = deliver_or_enqueue(Txn, ChPid, Message, State), |