diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2012-07-09 11:21:57 +0100 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2012-07-09 11:21:57 +0100 |
commit | 6c7532d5a7bb255f4209f13f6b6246ebd3ce4cf5 (patch) | |
tree | eadac0033157bafdd75692a5a688fad9b93cfaa9 /src | |
parent | 1a36bd727ec792b0a9b75da731f27b2fb8a89a02 (diff) | |
download | rabbitmq-server-6c7532d5a7bb255f4209f13f6b6246ebd3ce4cf5.tar.gz |
It did work, but we needed to do that in another place too...
Diffstat (limited to 'src')
-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; |