Skip to content

Commit d222d4c

Browse files
committed
Local shovels: try a passive declare before declaring source/dest queues
If queue arguments don't match, the shovel should still start as for amqp0.9.1 and amqp1.0
1 parent c4138d5 commit d222d4c

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

deps/rabbitmq_shovel/src/rabbit_local_shovel.erl

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -594,7 +594,12 @@ decl_queue(QName, QArgs, VHost, User) ->
594594
Method = #'queue.declare'{queue = QName,
595595
durable = true,
596596
arguments = Args},
597-
decl_fun([Method], VHost, User).
597+
try
598+
decl_fun([#'queue.declare'{queue = QName,
599+
passive = true}], VHost, User)
600+
catch exit:{amqp_error, not_found, _, _} ->
601+
decl_fun([Method], VHost, User)
602+
end.
598603

599604
dest_check_queue(none, _, _, _) ->
600605
ok;

0 commit comments

Comments
 (0)