diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 8e31cac4cd..c3de2c08e9 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -169,10 +169,9 @@ code_change(_OldVsn, State, _Extra) -> %%---------------------------------------------------------------------------- -declare(Recover, From, - State = #q{q = Q, - backing_queue = undefined, - backing_queue_state = undefined}) -> +declare(Recover, From, State = #q{q = Q, + backing_queue = undefined, + backing_queue_state = undefined}) -> {IsRecovering, MediatorPid} = recovery_status(Recover), case rabbit_amqqueue:internal_declare(Q, IsRecovering) of #amqqueue{} = Q1 -> |