diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-09-03 16:12:05 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-09-03 16:12:05 +0100 |
| commit | 2e0e201e7336fc9381b8e3a29579d5399fdfa42e (patch) | |
| tree | baf1defe25ece92d34e3ae4c74bb6af12a0cb533 /src/rabbit_mirror_queue_misc.erl | |
| parent | 5c0b1272675c8a78b714d2cf17e93a3f34db65d9 (diff) | |
| download | rabbitmq-server-2e0e201e7336fc9381b8e3a29579d5399fdfa42e.tar.gz | |
Dead lettering by policy.
Diffstat (limited to 'src/rabbit_mirror_queue_misc.erl')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index eded0411..2d55cad4 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -221,7 +221,7 @@ store_updated_slaves(Q = #amqqueue{slave_pids = SPids, Q1 = Q#amqqueue{sync_slave_pids = SSPids1}, ok = rabbit_amqqueue:store_queue(Q1), %% Wake it up so that we emit a stats event - rabbit_amqqueue:wake_up(Q1), + rabbit_amqqueue:notify_policy_changed(Q1), Q1. %%---------------------------------------------------------------------------- |