Skip to content

Commit d36b639

Browse files
Merge pull request #1010 from rabbitmq/rabbitmq-server-1007
Ignore policy_changed on slaves
2 parents 3906b1b + 1dd5afb commit d36b639

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/rabbit_mirror_queue_slave.erl

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -314,7 +314,12 @@ handle_cast({set_ram_duration_target, Duration},
314314
State = #state { backing_queue = BQ,
315315
backing_queue_state = BQS }) ->
316316
BQS1 = BQ:set_ram_duration_target(Duration, BQS),
317-
noreply(State #state { backing_queue_state = BQS1 }).
317+
noreply(State #state { backing_queue_state = BQS1 });
318+
319+
handle_cast(policy_changed, State) ->
320+
%% During partial partitions, we might end up receiving messages expected by a master
321+
%% Ignore them
322+
noreply(State).
318323

319324
handle_info(update_ram_duration, State = #state{backing_queue = BQ,
320325
backing_queue_state = BQS}) ->

0 commit comments

Comments
 (0)