From 1077a55194ca81e27ed4f239ea6b261014dfcbcd Mon Sep 17 00:00:00 2001 From: Michal Kuratczyk Date: Mon, 13 Jan 2025 15:51:39 +0100 Subject: [PATCH] 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. --- deps/rabbit/src/rabbit_stream_queue.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index 2a2b30b41ad..23c7e2d0725 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -329,7 +329,7 @@ consume(Q, Spec, #stream_client{} = QState0) AckRequired = not NoAck, rabbit_core_metrics:consumer_created( ChPid, ConsumerTag, ExclusiveConsume, AckRequired, - QName, ConsumerPrefetchCount, false, up, Args), + QName, ConsumerPrefetchCount, true, up, Args), %% reply needs to be sent before the stream %% begins sending maybe_send_reply(ChPid, OkMsg),