diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-12-04 13:59:58 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-12-04 13:59:58 +0000 |
| commit | 5c30e7cf1fd1502ed5b30da8a6617705f27cd34f (patch) | |
| tree | 8f64e3a46f1c9ab2e5981032629cdc4a23e4be85 | |
| parent | 95df21c84139e849fa1fb836b17020fa1ae26f04 (diff) | |
| parent | 8c4f3463f16461deb49591a580f98b39fca32a31 (diff) | |
| download | rabbitmq-server-5c30e7cf1fd1502ed5b30da8a6617705f27cd34f.tar.gz | |
Merge bug25335
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 52884410..173f7648 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -284,7 +284,11 @@ store_queue(Q = #amqqueue{durable = false}) -> ok = mnesia:write(rabbit_queue, Q, write), ok. -policy_changed(Q1, Q2) -> rabbit_mirror_queue_misc:update_mirrors(Q1, Q2). +policy_changed(Q1, Q2) -> + rabbit_mirror_queue_misc:update_mirrors(Q1, Q2), + %% Make sure we emit a stats event even if nothing + %% mirroring-related has changed - the policy may have changed anyway. + wake_up(Q1). start_queue_process(Node, Q) -> {ok, Pid} = rabbit_amqqueue_sup:start_child(Node, [Q]), |