Skip to content

Commit eeff58e

Browse files
mkuratczykmergify[bot]
authored andcommitted
Stream queue: consumers are active by default
Without this change, consumers using protocols other than the stream protocol would display as inactive in the Management UI/API and CLI commands, even though they were receiving messages. (cherry picked from commit 1077a55)
1 parent afd75f1 commit eeff58e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbit/src/rabbit_stream_queue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,7 @@ consume(Q, Spec, #stream_client{} = QState0)
328328
AckRequired = not NoAck,
329329
rabbit_core_metrics:consumer_created(
330330
ChPid, ConsumerTag, ExclusiveConsume, AckRequired,
331-
QName, ConsumerPrefetchCount, false, up, Args),
331+
QName, ConsumerPrefetchCount, true, up, Args),
332332
%% reply needs to be sent before the stream
333333
%% begins sending
334334
maybe_send_reply(ChPid, OkMsg),

0 commit comments

Comments
 (0)