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 | 16d4ec43b80b8d2e919840e9c2cb8fe3fd95250f (patch) | |
| tree | 9b3828bb49141a823493477c2316e8d70bdfb6c9 | |
| parent | 99927387382064f92603c3255f9ab5c9f8de10f8 (diff) | |
| download | rabbitmq-server-bug24720.tar.gz | |
I am more dubious about this one. But not enough to take it out.bug24720
| -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 2d7bd9a1..60d3e027 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 |