diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-10-09 16:17:28 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-10-09 16:17:28 +0100 |
| commit | 26f19a76d71565ff1f46567e0abb77e54d0a4879 (patch) | |
| tree | 5b1604be76342533d4cec8976d0cd35016f9df27 /src | |
| parent | c3ef17d9515ab2cd949f82cc2a6e0bb0662aea78 (diff) | |
| download | rabbitmq-server-git-26f19a76d71565ff1f46567e0abb77e54d0a4879.tar.gz | |
Oops
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] |