diff options
| -rw-r--r-- | src/rabbit_fifo.erl | 2 | ||||
| -rw-r--r-- | test/rabbit_fifo_SUITE.erl | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 8332043af9..97e5f6e901 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -839,7 +839,7 @@ activate_next_consumer(#?MODULE{consumers = Cons, single_active, Effects0), {State, Effects}; [] -> - {State0, Effects0} + {State0, [{aux, inactive} | Effects0]} end; _ -> {State0, Effects0} diff --git a/test/rabbit_fifo_SUITE.erl b/test/rabbit_fifo_SUITE.erl index e45ab2371c..cf14a68d9d 100644 --- a/test/rabbit_fifo_SUITE.erl +++ b/test/rabbit_fifo_SUITE.erl @@ -1025,7 +1025,7 @@ active_flag_not_updated_when_consumer_suspected_unsuspected_and_single_active_co {State2, _, Effects2} = apply(#{}, {down, Pid1, noconnection}, State1), % one monitor and one consumer status update (deactivated) - ?assertEqual(2, length(Effects2)), + ?assertEqual(3, length(Effects2)), {_, _, Effects3} = apply(#{index => 1}, {nodeup, node(self())}, State2), % for each consumer: 1 effect to monitor the consumer PID |