@@ -108,7 +108,8 @@ init_per_suite(Config0) ->
108108 " source_queue_down" ,
109109 " dest_queue_down" ,
110110 " inbound_link_detached" ,
111- " not_found"
111+ " not_found" ,
112+ " dependent process"
112113 ]}
113114 ]),
114115 rabbit_ct_helpers :run_setup_steps (
@@ -318,7 +319,7 @@ missing_src_queue_with_src_predeclared(Config) ->
318319 Ch , # 'queue.bind' {queue = Dest ,
319320 exchange = <<" dest-ex" >>,
320321 routing_key = <<" dest-key" >>}),
321-
322+
322323 set_param_nowait (Config ,
323324 ? PARAM , ? config (shovel_args , Config ) ++
324325 [{<<" src-queue" >>, Src },
@@ -327,7 +328,7 @@ missing_src_queue_with_src_predeclared(Config) ->
327328 {<<" dest-exchange-key" >>, <<" dest-key" >>}]),
328329 await_shovel (Config , 0 , ? PARAM , terminated ),
329330 expect_missing_queue (Ch , Src ),
330-
331+
331332 with_amqp091_ch (
332333 Config ,
333334 fun (Ch2 ) ->
@@ -368,7 +369,7 @@ missing_dest_queue_with_dest_predeclared(Config) ->
368369 fun (Ch2 ) ->
369370 amqp_channel :call (
370371 Ch2 , # 'queue.declare' {queue = Dest ,
371- durable = true }),
372+ durable = true }),
372373 await_shovel (Config , 0 , ? PARAM , running ),
373374 amqp091_publish_expect (Ch2 , <<" amq.direct" >>, <<" src-key" >>, Dest , <<" hello!" >>)
374375 end )
@@ -392,15 +393,15 @@ missing_src_queue_without_src_predeclared(Config) ->
392393 Ch , # 'queue.bind' {queue = Dest ,
393394 exchange = <<" dest-ex" >>,
394395 routing_key = <<" dest-key" >>}),
395-
396+
396397 set_param_nowait (Config , ? PARAM ,
397398 ? config (shovel_args , Config ) ++
398399 [{<<" src-queue" >>, Src },
399400 {<<" dest-exchange" >>, <<" dest-ex" >>},
400401 {<<" dest-exchange-key" >>, <<" dest-key" >>}]),
401402 await_shovel (Config , 0 , ? PARAM , terminated ),
402403 expect_missing_queue (Ch , Src ),
403-
404+
404405 with_amqp091_ch (
405406 Config ,
406407 fun (Ch2 ) ->
0 commit comments