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 | 348be40e2718bbccb1ec98dfb1b9598ca34af784 (patch) | |
| tree | 87dcee45f7cd3bbf53aeb1d825e334ddd2d64cb3 | |
| parent | 536bf6cb36806f9163507d96b0e669bc7fdf9d44 (diff) | |
| download | rabbitmq-server-348be40e2718bbccb1ec98dfb1b9598ca34af784.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 ec6e500f..953abcd2 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. |