Merge pull request #13063 from rabbitmq/stream-consumer-activity

Stream queue: consumers are active by default
rabbitmq · Jan 13, 2025 · a9e972f · a9e972f
2 parents 208d3d6 + 1077a55
commit a9e972f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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),