From 7b57750e4e3ab8df3ee8159dbcf6d7f4d4f18644 Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Tue, 29 Mar 2022 09:03:02 +0400 Subject: [PATCH] Federated queue suite: make it easier to identify messages --- deps/rabbitmq_federation/test/queue_SUITE.erl | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/deps/rabbitmq_federation/test/queue_SUITE.erl b/deps/rabbitmq_federation/test/queue_SUITE.erl index 2fab15b940..486684285c 100644 --- a/deps/rabbitmq_federation/test/queue_SUITE.erl +++ b/deps/rabbitmq_federation/test/queue_SUITE.erl @@ -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 = <>, + publish_expect(Ch, <<>>, UpstreamQ, DownstreamQ, Payload). expect_federation(Ch, UpstreamQ, DownstreamQ, Timeout) -> - publish_expect(Ch, <<>>, UpstreamQ, DownstreamQ, <<"HELLO">>, Timeout). + Base = <<"HELLO">>, + Payload = <>, + publish_expect(Ch, <<>>, UpstreamQ, DownstreamQ, Payload, Timeout). expect_no_federation(Ch, UpstreamQ, DownstreamQ) -> publish(Ch, <<>>, UpstreamQ, <<"HELLO">>),