Merge pull request #14245 from rabbitmq/amqp_filter_set_bug
Trigger a 4.2.x alpha release build / trigger_alpha_build (push) Waiting to run Details
Test (make) / Build and Xref (1.18, 26) (push) Waiting to run Details
Test (make) / Build and Xref (1.18, 27) (push) Waiting to run Details
Test (make) / Build and Xref (1.18, 28) (push) Waiting to run Details
Test (make) / Test (1.18, 28, khepri) (push) Waiting to run Details
Test (make) / Test (1.18, 28, mnesia) (push) Waiting to run Details
Test (make) / Test mixed clusters (1.18, 28, khepri) (push) Waiting to run Details
Test (make) / Test mixed clusters (1.18, 28, mnesia) (push) Waiting to run Details
Test (make) / Type check (1.18, 28) (push) Waiting to run Details

Deny `amqp_filter_set_bug` by default
This commit is contained in:
David Ansari 2025-07-17 15:19:27 +02:00 committed by GitHub
commit a43e2c5201
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 2 deletions

View File

@ -34,7 +34,7 @@
-rabbit_deprecated_feature(
{amqp_filter_set_bug,
#{deprecation_phase => permitted_by_default,
#{deprecation_phase => denied_by_default,
doc_url => "https://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-filter-set"
}}).

View File

@ -199,7 +199,8 @@ module Test =
for spec in specs do
printfn "testing streams spec %A" spec
let filterSet = Map()
filterSet.Add(Symbol "rabbitmq:stream-offset-spec", spec)
let describedValue = DescribedValue(Symbol "rabbitmq:stream-offset-spec", spec)
filterSet.Add(Symbol "my offset", describedValue)
let source = Source(Address = address,
FilterSet = filterSet)
let attach = Attach(Source = source)