From e578ea65ef37af17ce2de6160875b8d6f0f356ce Mon Sep 17 00:00:00 2001 From: David Ansari Date: Fri, 12 Jul 2024 16:58:40 +0200 Subject: [PATCH] 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 (cherry picked from commit 3863db39894fd5c3849df5c2948f2855ebea2978) --- deps/rabbit/src/rabbit_classic_queue.erl | 2 +- deps/rabbit/src/rabbit_stream_queue.erl | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/deps/rabbit/src/rabbit_classic_queue.erl b/deps/rabbit/src/rabbit_classic_queue.erl index 6457c5584e70..5878347349d2 100644 --- a/deps/rabbit/src/rabbit_classic_queue.erl +++ b/deps/rabbit/src/rabbit_classic_queue.erl @@ -572,7 +572,7 @@ capabilities() -> true -> [<<"x-queue-leader-locator">>]; false -> [] end, - consumer_arguments => [<<"x-priority">>, <<"x-credit">>], + consumer_arguments => [<<"x-priority">>], server_named => true}. notify_decorators(Q) when ?is_amqqueue(Q) -> diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index 2a3373004683..37f3b52e2e42 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -1267,7 +1267,9 @@ capabilities() -> queue_arguments => [<<"x-max-length-bytes">>, <<"x-queue-type">>, <<"x-max-age">>, <<"x-stream-max-segment-size-bytes">>, <<"x-initial-cluster-size">>, <<"x-queue-leader-locator">>], - consumer_arguments => [<<"x-stream-offset">>], + consumer_arguments => [<<"x-stream-offset">>, + <<"x-stream-filter">>, + <<"x-stream-match-unfiltered">>], server_named => false}. notify_decorators(Q) when ?is_amqqueue(Q) ->