diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-07-19 10:51:36 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-07-19 10:51:36 +0100 |
| commit | 1888720f4890ef06057099642cae84273d0d2c81 (patch) | |
| tree | 00d0f6f111568b9cef8eb6504a5eeb790e529145 | |
| parent | 64aacf077f8f18a3c821b70ff03b31c8e77b31cf (diff) | |
| download | rabbitmq-server-git-1888720f4890ef06057099642cae84273d0d2c81.tar.gz | |
Actually, for the bookkeeping mgmt wants, this is better.
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 6 |
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; |
