Skip to content

Commit b58b0ba

Browse files
MarcialRosalesmergify[bot]
authored andcommitted
More clean up
(cherry picked from commit 61c9cf2)
1 parent 66a46b9 commit b58b0ba

File tree

3 files changed

+3
-5
lines changed

3 files changed

+3
-5
lines changed

deps/rabbitmq_shovel/src/rabbit_amqp091_shovel.erl

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,13 +94,11 @@ init_source(Conf = #{ack_mode := AckMode,
9494
NoAck = AckMode =:= no_ack,
9595
case NoAck of
9696
false ->
97-
rabbit_log:debug("init_source. calling basic.qos ~p", [Prefetch]),
9897
#'basic.qos_ok'{} =
9998
amqp_channel:call(Chan, #'basic.qos'{prefetch_count = Prefetch}),
10099
ok;
101100
true -> ok
102101
end,
103-
rabbit_log:debug("init_source. calling remaining"),
104102
Remaining = remaining(Chan, Conf),
105103
case Remaining of
106104
0 ->

deps/rabbitmq_shovel/src/rabbit_shovel_config.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ parse(ShovelName, Config0) ->
6969
try
7070
validate(Config0),
7171
case is_legacy(Config0) of
72-
true ->
72+
true ->
7373
Config = convert_from_legacy(Config0),
7474
parse_current(ShovelName, Config);
7575
false ->
@@ -125,7 +125,7 @@ validate_uris0([]) -> ok.
125125

126126
parse_current(ShovelName, Config) ->
127127
{source, Source} = proplists:lookup(source, Config),
128-
validate(Source),
128+
validate(Source),
129129
SrcMod = resolve_module(proplists:get_value(protocol, Source, amqp091)),
130130
{destination, Destination} = proplists:lookup(destination, Config),
131131
validate(Destination),

deps/rabbitmq_shovel/src/rabbit_shovel_parameters.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -455,7 +455,7 @@ parse_amqp091_source(Def) ->
455455
%% available to query the runtime parameters.
456456
Details = maps:from_list([{K, V} || {K, V} <- [{source_exchange, SrcX},
457457
{source_exchange_key, SrcXKey}],
458-
V =/= none]),
458+
V =/= none]),
459459
{maps:merge(#{module => rabbit_amqp091_shovel,
460460
uris => SrcURIs,
461461
resource_decl => SrcDeclFun,

0 commit comments

Comments
 (0)