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 | 6b3d25e4261e09677612a65e2e0be0bd7acacfa9 (patch) | |
| tree | eadac0033157bafdd75692a5a688fad9b93cfaa9 | |
| parent | 0acd0fd882f7a47d3a57897dffafa3152e4394e1 (diff) | |
| download | rabbitmq-server-git-6b3d25e4261e09677612a65e2e0be0bd7acacfa9.tar.gz | |
It did work, but we needed to do that in another place too...
| -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 4d26a4d0c3..fbffbee196 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 ee1d2b0710..a858ee4e12 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; |