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 | aced165290575062a98f6e5774c3780f40ee3dc0 (patch) | |
| tree | 8f64e3a46f1c9ab2e5981032629cdc4a23e4be85 /src | |
| parent | 61c5c608ced2897829af7ff7b6a7612728783d47 (diff) | |
| parent | f0d85a5fb8de75df5ea33cfc9dd9e1efe0014f9f (diff) | |
| download | rabbitmq-server-git-aced165290575062a98f6e5774c3780f40ee3dc0.tar.gz | |
Merge bug25335
Diffstat (limited to 'src')
| -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 5288441058..173f76481b 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]), |