summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-07-09 11:21:57 +0100
committerSimon MacMullen <simon@rabbitmq.com>2012-07-09 11:21:57 +0100
commit6c7532d5a7bb255f4209f13f6b6246ebd3ce4cf5 (patch)
treeeadac0033157bafdd75692a5a688fad9b93cfaa9
parent1a36bd727ec792b0a9b75da731f27b2fb8a89a02 (diff)
downloadrabbitmq-server-6c7532d5a7bb255f4209f13f6b6246ebd3ce4cf5.tar.gz
It did work, but we needed to do that in another place too...
-rw-r--r--src/rabbit_mirror_queue_misc.erl1
-rw-r--r--src/rabbit_mirror_queue_slave.erl2
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;