root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 8 Packages Projects Releases Wiki Activity

Fix failing test case `streams` 

Fix
```
make -C deps/rabbit ct-amqp_dotnet t=cluster_size_1:streams
```
This commit is contained in:
David Ansari 2025-07-17 11:29:53 +02:00
parent 4c73edd923
commit a850505b18
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/rabbit/test/amqp_dotnet_SUITE_data/fsharp-tests/Program.fs vendored
View File

@ -199,7 +199,8 @@ module Test =
for spec in specs do for spec in specs do
printfn "testing streams spec %A" spec printfn "testing streams spec %A" spec
let filterSet = Map() 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, let source = Source(Address = address,
FilterSet = filterSet) FilterSet = filterSet)
let attach = Attach(Source = source) let attach = Attach(Source = source)