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" >>, ? EXPECT_FEDERATION_TIMEOUT ),
197
- expect_federation (Ch , <<" upstream2" >>, <<" fed12.downstream" >>, ? EXPECT_FEDERATION_TIMEOUT )
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 ), [
0 commit comments