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 00dae70 commit d8add90Copy full SHA for d8add90
deps/rabbitmq_shovel/src/rabbit_local_shovel.erl
@@ -256,12 +256,10 @@ source_protocol(_State) ->
256
dest_protocol(_State) ->
257
local.
258
259
-source_endpoint(#{source := #{queue := Queue,
260
- exchange := SrcX,
+source_endpoint(#{source := #{exchange := SrcX,
261
routing_key := SrcXKey}}) ->
262
[{src_exchange, SrcX},
263
- {src_exchange_key, SrcXKey},
264
- {src_queue, Queue}];
+ {src_exchange_key, SrcXKey}];
265
source_endpoint(#{source := #{queue := Queue}}) ->
266
[{src_queue, Queue}];
267
source_endpoint(_Config) ->
0 commit comments