We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0ecf3d4 commit 6c0ba03Copy full SHA for 6c0ba03
deps/rabbitmq_stream/test/rabbit_stream_SUITE.erl
@@ -324,12 +324,14 @@ test_server(Transport, Config) ->
324
Stream = <<"stream1">>,
325
C3 = test_create_stream(Transport, S, Stream, C2),
326
PublisherId = 42,
327
+ ?assertMatch(#{publishers := 0}, get_global_counters(Config)),
328
C4 = test_declare_publisher(Transport, S, PublisherId, Stream, C3),
329
?assertMatch(#{publishers := 1}, get_global_counters(Config)),
330
Body = <<"hello">>,
331
C5 = test_publish_confirm(Transport, S, PublisherId, Body, C4),
332
C6 = test_publish_confirm(Transport, S, PublisherId, Body, C5),
333
SubscriptionId = 42,
334
+ ?assertMatch(#{consumers := 0}, get_global_counters(Config)),
335
C7 = test_subscribe(Transport, S, SubscriptionId, Stream, C6),
336
?assertMatch(#{consumers := 1}, get_global_counters(Config)),
337
C8 = test_deliver(Transport, S, SubscriptionId, 0, Body, C7),
0 commit comments