Skip to content

Commit ca70496

Browse files
Merge pull request #13065 from rabbitmq/mergify/bp/v4.0.x/pr-13063
Stream queue: consumers are active by default (backport #13063)
2 parents afd75f1 + eeff58e commit ca70496

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)