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

Federated queue suite: make it easier to identify messages

This commit is contained in:
Michael Klishin 2022-03-29 09:03:02 +04:00
parent 61f70bc51b
commit 7b57750e4e
No known key found for this signature in database
GPG Key ID: E80EDCFA0CDB21EE
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
deps/rabbitmq_federation/test/queue_SUITE.erl vendored
View File

@ -193,8 +193,8 @@ multiple_upstreams(Config) ->
TargetArgs = ?config(target_queue_args, Config),
with_ch(Config,
fun (Ch) ->
expect_federation(Ch, <<"upstream">>, <<"fed12.downstream">>),
expect_federation(Ch, <<"upstream2">>, <<"fed12.downstream">>)
expect_federation(Ch, <<"upstream">>, <<"fed12.downstream">>, ?EXPECT_FEDERATION_TIMEOUT),
expect_federation(Ch, <<"upstream2">>, <<"fed12.downstream">>, ?EXPECT_FEDERATION_TIMEOUT)
end, [q(<<"upstream">>, SourceArgs),
q(<<"upstream2">>, SourceArgs),
q(<<"fed12.downstream">>, TargetArgs)]).
@ -408,10 +408,14 @@ expect_empty(Ch, Q) ->
rabbit_federation_test_util:expect_empty(Ch, Q).
expect_federation(Ch, UpstreamQ, DownstreamQ) ->
publish_expect(Ch, <<>>, UpstreamQ, DownstreamQ, <<"HELLO">>).
Base = <<"HELLO">>,
Payload = <<Base/binary, "-to-", UpstreamQ/binary>>,
publish_expect(Ch, <<>>, UpstreamQ, DownstreamQ, Payload).
expect_federation(Ch, UpstreamQ, DownstreamQ, Timeout) ->
publish_expect(Ch, <<>>, UpstreamQ, DownstreamQ, <<"HELLO">>, Timeout).
Base = <<"HELLO">>,
Payload = <<Base/binary, "-to-", UpstreamQ/binary>>,
publish_expect(Ch, <<>>, UpstreamQ, DownstreamQ, Payload, Timeout).
expect_no_federation(Ch, UpstreamQ, DownstreamQ) ->
publish(Ch, <<>>, UpstreamQ, <<"HELLO">>),