diff options
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
2 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 4d26a4d0..fbffbee1 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -77,6 +77,7 @@ remove_from_queue(QueueName, DeadPids) -> slave_pids = SPids1, sync_slave_pids = SSPids1}, ok = rabbit_amqqueue:store_queue(Q1), + rabbit_amqqueue:info(Q1, [name]), %% Wake it up {ok, QPid1, [QPid | SPids] -- Alive}; _ -> %% Master has changed, and we're not it, diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index ee1d2b07..a858ee4e 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -917,7 +917,7 @@ set_synchronised(true, State = #state { q = Q = #amqqueue { name = QName }, ok = rabbit_amqqueue:store_queue(Q2) end end), - rabbit_amqqueue:info(Q, [name]), %% Wake it up TODO this doesn't work + rabbit_amqqueue:info(Q, [name]), %% Wake it up State #state { synchronised = true }; set_synchronised(true, State) -> State; |