summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-07-19 10:51:36 +0100
committerSimon MacMullen <simon@rabbitmq.com>2011-07-19 10:51:36 +0100
commit1888720f4890ef06057099642cae84273d0d2c81 (patch)
tree00d0f6f111568b9cef8eb6504a5eeb790e529145
parent64aacf077f8f18a3c821b70ff03b31c8e77b31cf (diff)
downloadrabbitmq-server-git-1888720f4890ef06057099642cae84273d0d2c81.tar.gz
Actually, for the bookkeeping mgmt wants, this is better.
-rw-r--r--src/rabbit_mirror_queue_slave.erl6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl
index 6db8e7ad77..001b0d0031 100644
--- a/src/rabbit_mirror_queue_slave.erl
+++ b/src/rabbit_mirror_queue_slave.erl
@@ -893,10 +893,10 @@ maybe_store_ack(true, MsgId, AckTag, State = #state { msg_id_ack = MA,
%% We intentionally leave out the head where a slave becomes
%% unsynchronised: we assert that can never happen.
-set_synchronised(true, State = #state { master_pid = MasterPid,
+set_synchronised(true, State = #state { q = #amqqueue{name = QName},
synchronised = false }) ->
- rabbit_event:notify(queue_slave_synchronised, [{master_pid, MasterPid},
- {pid, self()}]),
+ rabbit_event:notify(queue_slave_synchronised, [{name, QName},
+ {pid, self()}]),
State #state { synchronised = true };
set_synchronised(true, State) ->
State;