Skip to content

Commit 3863db3

Browse files
committed
Fix queue type consumer arguments
see https://www.rabbitmq.com/blog/2023/10/24/stream-filtering-internals#bonus-stream-filtering-on-amqp `x-credit` was used by the 3.13 AMQP 1.0 plugin
1 parent d4ea90d commit 3863db3

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

deps/rabbit/src/rabbit_classic_queue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -572,7 +572,7 @@ capabilities() ->
572572
true -> [<<"x-queue-leader-locator">>];
573573
false -> []
574574
end,
575-
consumer_arguments => [<<"x-priority">>, <<"x-credit">>],
575+
consumer_arguments => [<<"x-priority">>],
576576
server_named => true}.
577577

578578
notify_decorators(Q) when ?is_amqqueue(Q) ->

deps/rabbit/src/rabbit_stream_queue.erl

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1267,7 +1267,9 @@ capabilities() ->
12671267
queue_arguments => [<<"x-max-length-bytes">>, <<"x-queue-type">>,
12681268
<<"x-max-age">>, <<"x-stream-max-segment-size-bytes">>,
12691269
<<"x-initial-cluster-size">>, <<"x-queue-leader-locator">>],
1270-
consumer_arguments => [<<"x-stream-offset">>],
1270+
consumer_arguments => [<<"x-stream-offset">>,
1271+
<<"x-stream-filter">>,
1272+
<<"x-stream-match-unfiltered">>],
12711273
server_named => false}.
12721274

12731275
notify_decorators(Q) when ?is_amqqueue(Q) ->

0 commit comments

Comments
 (0)