@@ -2803,20 +2803,20 @@ rebalance(Config) ->
28032803 Q5 = <<" st5" >>,
28042804
28052805 ? 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 }])),
28082808 ? 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 }])),
28112811 ? 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 }])),
28142814 ? 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 }])),
28172817 ? 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 }])),
28202820
28212821 NumMsgs = 100 ,
28222822 Data = crypto :strong_rand_bytes (100 ),
0 commit comments