diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2016-10-25 13:51:41 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2016-10-25 13:51:41 +0100 |
| commit | 1dd5afb1fc18ee607ea7b2d9eda0a62c6f6865d6 (patch) | |
| tree | 002fc27e81099f573a53f809b559c921ade753ca /src | |
| parent | 3906b1bfd21c83ba33ef5de491a993f8d4d9fc03 (diff) | |
| download | rabbitmq-server-git-1dd5afb1fc18ee607ea7b2d9eda0a62c6f6865d6.tar.gz | |
Ignore policy_changed on slaves
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 4770018f9e..6017e5a028 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -314,7 +314,12 @@ handle_cast({set_ram_duration_target, Duration}, State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> BQS1 = BQ:set_ram_duration_target(Duration, BQS), - noreply(State #state { backing_queue_state = BQS1 }). + noreply(State #state { backing_queue_state = BQS1 }); + +handle_cast(policy_changed, State) -> + %% During partial partitions, we might end up receiving messages expected by a master + %% Ignore them + noreply(State). handle_info(update_ram_duration, State = #state{backing_queue = BQ, backing_queue_state = BQS}) -> |