15
15
16
16
-import (rabbit_federation_test_util ,
17
17
[wait_for_federation /2 , expect /3 , expect /4 ,
18
- set_upstream /4 , set_upstream /5 , clear_upstream /3 , clear_upstream_set /3 ,
18
+ set_upstream /4 , set_upstream /5 , clear_upstream /3 , set_upstream_set / 4 , clear_upstream_set /3 ,
19
19
set_policy /5 , clear_policy /3 ,
20
20
set_policy_pattern /5 , set_policy_upstream /5 , q /2 , with_ch /3 ,
21
21
maybe_declare_queue /3 , delete_queue /2 ,
@@ -33,7 +33,6 @@ all() ->
33
33
34
34
groups () ->
35
35
ClusterSize1 = [simple ,
36
- multiple_upstreams ,
37
36
multiple_upstreams_pattern ,
38
37
multiple_downstreams ,
39
38
message_flow ,
@@ -188,17 +187,6 @@ simple(Config) ->
188
187
expect_federation (Ch , <<" upstream" >>, <<" fed.downstream" >>)
189
188
end , upstream_downstream (Config )).
190
189
191
- multiple_upstreams (Config ) ->
192
- SourceArgs = ? config (source_queue_args , Config ),
193
- TargetArgs = ? config (target_queue_args , Config ),
194
- with_ch (Config ,
195
- fun (Ch ) ->
196
- expect_federation (Ch , <<" upstream" >>, <<" fed12.downstream" >>),
197
- expect_federation (Ch , <<" upstream2" >>, <<" fed12.downstream" >>)
198
- end , [q (<<" upstream" >>, SourceArgs ),
199
- q (<<" upstream2" >>, SourceArgs ),
200
- q (<<" fed12.downstream" >>, TargetArgs )]).
201
-
202
190
multiple_upstreams_pattern (Config ) ->
203
191
set_upstream (Config , 0 , <<" local453x" >>,
204
192
rabbit_ct_broker_helpers :node_uri (Config , 0 ), [
@@ -408,10 +396,14 @@ expect_empty(Ch, Q) ->
408
396
rabbit_federation_test_util :expect_empty (Ch , Q ).
409
397
410
398
expect_federation (Ch , UpstreamQ , DownstreamQ ) ->
411
- publish_expect (Ch , <<>>, UpstreamQ , DownstreamQ , <<" HELLO" >>).
399
+ Base = <<" HELLO" >>,
400
+ Payload = <<Base /binary , " -to-" , UpstreamQ /binary >>,
401
+ publish_expect (Ch , <<>>, UpstreamQ , DownstreamQ , Payload ).
412
402
413
403
expect_federation (Ch , UpstreamQ , DownstreamQ , Timeout ) ->
414
- publish_expect (Ch , <<>>, UpstreamQ , DownstreamQ , <<" HELLO" >>, Timeout ).
404
+ Base = <<" HELLO" >>,
405
+ Payload = <<Base /binary , " -to-" , UpstreamQ /binary >>,
406
+ publish_expect (Ch , <<>>, UpstreamQ , DownstreamQ , Payload , Timeout ).
415
407
416
408
expect_no_federation (Ch , UpstreamQ , DownstreamQ ) ->
417
409
publish (Ch , <<>>, UpstreamQ , <<" HELLO" >>),
0 commit comments