@@ -2803,20 +2803,20 @@ rebalance(Config) ->
2803
2803
Q5 = <<" st5" >>,
2804
2804
2805
2805
? assertEqual ({'queue.declare_ok' , Q1 , 0 , 0 },
2806
- declare (Ch , Q1 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2807
- {<<" x-initial-cluster-size" >>, long , 3 }])),
2806
+ declare (Config , Server0 , Q1 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2807
+ {<<" x-initial-cluster-size" >>, long , 3 }])),
2808
2808
? assertEqual ({'queue.declare_ok' , Q2 , 0 , 0 },
2809
- declare (Ch , Q2 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2810
- {<<" x-initial-cluster-size" >>, long , 3 }])),
2809
+ declare (Config , Server0 , Q2 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2810
+ {<<" x-initial-cluster-size" >>, long , 3 }])),
2811
2811
? assertEqual ({'queue.declare_ok' , Q3 , 0 , 0 },
2812
- declare (Ch , Q3 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2813
- {<<" x-initial-cluster-size" >>, long , 3 }])),
2812
+ declare (Config , Server0 , Q3 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2813
+ {<<" x-initial-cluster-size" >>, long , 3 }])),
2814
2814
? assertEqual ({'queue.declare_ok' , Q4 , 0 , 0 },
2815
- declare (Ch , Q4 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2816
- {<<" x-initial-cluster-size" >>, long , 3 }])),
2815
+ declare (Config , Server0 , Q4 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2816
+ {<<" x-initial-cluster-size" >>, long , 3 }])),
2817
2817
? assertEqual ({'queue.declare_ok' , Q5 , 0 , 0 },
2818
- declare (Ch , Q5 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2819
- {<<" x-initial-cluster-size" >>, long , 3 }])),
2818
+ declare (Config , Server0 , Q5 , [{<<" x-queue-type" >>, longstr , <<" stream" >>},
2819
+ {<<" x-initial-cluster-size" >>, long , 3 }])),
2820
2820
2821
2821
NumMsgs = 100 ,
2822
2822
Data = crypto :strong_rand_bytes (100 ),
0 commit comments