diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2013-08-23 11:06:53 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2013-08-23 11:06:53 +0100 |
| commit | e0ee6a34cf342aae1613853bbc21fbbe080df0c8 (patch) | |
| tree | 87dcee45f7cd3bbf53aeb1d825e334ddd2d64cb3 | |
| parent | 719e5e176b438a383f7ce472a8c29516ca8f2558 (diff) | |
| download | rabbitmq-server-git-e0ee6a34cf342aae1613853bbc21fbbe080df0c8.tar.gz | |
Log reason for restart
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index ec6e500f57..953abcd271 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -80,7 +80,7 @@ set_maximum_since_use(QPid, Age) -> info(QPid) -> gen_server2:call(QPid, info, infinity). -init(Q = #amqqueue { name = QName }) -> +init(Q = #amqqueue { name = QName, pid = MPid }) -> %% We join the GM group before we add ourselves to the amqqueue %% record. As a result: %% 1. We can receive msgs from GM that correspond to messages we will @@ -139,6 +139,8 @@ init(Q = #amqqueue { name = QName }) -> gm:leave(GM), ignore; master_recovery_detected -> + rabbit_log:info("Restarting to prevent conflict with ~p on ~p~n", + [node(MPid), rabbit_misc:rs(QName)]), init:restart(), ignore end. |