We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4a64d4f commit 890ef82Copy full SHA for 890ef82
deps/rabbitmq_shovel/src/rabbit_local_shovel.erl
@@ -244,12 +244,10 @@ source_protocol(_State) ->
244
dest_protocol(_State) ->
245
local.
246
247
-source_endpoint(#{source := #{queue := Queue,
248
- exchange := SrcX,
+source_endpoint(#{source := #{exchange := SrcX,
249
routing_key := SrcXKey}}) ->
250
[{src_exchange, SrcX},
251
- {src_exchange_key, SrcXKey},
252
- {src_queue, Queue}];
+ {src_exchange_key, SrcXKey}];
253
source_endpoint(#{source := #{queue := Queue}}) ->
254
[{src_queue, Queue}];
255
source_endpoint(_Config) ->
0 commit comments