From eeff58eda666e7ab00e283d501fed6940b28d0d3 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. (cherry picked from commit 1077a55194ca81e27ed4f239ea6b261014dfcbcd) --- 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 ec594c51f989..6ab5f0d4501f 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -328,7 +328,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),