Skip to content

Commit 1077a55

Browse files
committed
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.
1 parent 208d3d6 commit 1077a55

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
@@ -329,7 +329,7 @@ consume(Q, Spec, #stream_client{} = QState0)
329329
AckRequired = not NoAck,
330330
rabbit_core_metrics:consumer_created(
331331
ChPid, ConsumerTag, ExclusiveConsume, AckRequired,
332-
QName, ConsumerPrefetchCount, false, up, Args),
332+
QName, ConsumerPrefetchCount, true, up, Args),
333333
%% reply needs to be sent before the stream
334334
%% begins sending
335335
maybe_send_reply(ChPid, OkMsg),

0 commit comments

Comments
 (0)