diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-07-13 11:55:24 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-07-13 11:55:24 +0100 |
| commit | 35467ac38fbf9be2084b03967f6ca9151c0b609d (patch) | |
| tree | 9b3828bb49141a823493477c2316e8d70bdfb6c9 | |
| parent | 8ef211effafbfbfdb047fbfeebf36481d186d8fd (diff) | |
| download | rabbitmq-server-git-35467ac38fbf9be2084b03967f6ca9151c0b609d.tar.gz | |
I am more dubious about this one. But not enough to take it out.
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 2d7bd9a112..60d3e027fb 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -457,6 +457,8 @@ promote_me(From, #state { q = Q = #amqqueue { name = QName }, rabbit_mirror_queue_master:length_fun()), true = unlink(GM), gen_server2:reply(From, {promote, CPid}), + %% TODO this has been in here since the beginning, but it's not + %% obvious if it is needed. Investigate... ok = gm:confirmed_broadcast(GM, master_changed), %% Everything that we're monitoring, we need to ensure our new |