diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-08-11 14:15:34 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-08-11 14:15:34 +0100 |
| commit | 1c59d0a24a18e7deb4240cc79a473d37780044ea (patch) | |
| tree | 7f2791a0003bca2c08d3fc440bb7ebdee47abdc6 /src | |
| parent | 1883df90676fe5db719ec6469aa95275821870c6 (diff) | |
| download | rabbitmq-server-git-1c59d0a24a18e7deb4240cc79a473d37780044ea.tar.gz | |
More consistency
Diffstat (limited to 'src')
| -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 0640014328..3c45398133 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -427,7 +427,7 @@ promote_me(From, #state { q = Q = #amqqueue { name = QName }, sender_queues = SQ, msg_id_ack = MA, msg_id_status = MS, - known_senders = KS}) -> + known_senders = KS }) -> rabbit_event:notify(queue_slave_promoted, [{pid, self()}, {name, QName}]), rabbit_log:info("Mirrored-queue (~s): Promoting slave ~s to master~n", @@ -896,8 +896,8 @@ 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 {q = #amqqueue { name = QName }, - synchronised = false }) -> +set_synchronised(true, State = #state { q = #amqqueue { name = QName }, + synchronised = false }) -> rabbit_event:notify(queue_slave_synchronised, [{pid, self()}, {name, QName}]), State #state { synchronised = true }; |