diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_prequeue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_prequeue.erl b/src/rabbit_prequeue.erl index ba430ebadf..e7c2b5e43a 100644 --- a/src/rabbit_prequeue.erl +++ b/src/rabbit_prequeue.erl @@ -71,7 +71,7 @@ init(#amqqueue{name = QueueName}, restart) -> true -> false = LocalOrMasterDown, %% assertion rabbit_mirror_queue_slave:go(self(), async), rabbit_mirror_queue_slave:init(Q); %% [1] - false -> case LocalOrMasterDown andalso, Slaves =:= [] of + false -> case LocalOrMasterDown andalso Slaves =:= [] of true -> crash_restart(Q); %% [2] false -> timer:sleep(25), init(Q, restart) %% [3] |