Local shovels: remove unused prefetch count

Author: dcorbacho

deps/rabbitmq_shovel/src/rabbit_local_shovel.erl

@@ -66,9 +66,6 @@
 }).
 
 parse(_Name, {source, Source}) ->
-    Prefetch = parse_parameter(prefetch_count, fun parse_non_negative_integer/1,
-                               proplists:get_value(prefetch_count, Source,
-                                                   ?DEFAULT_PREFETCH)),
     Queue = parse_parameter(queue, fun parse_binary/1,
                             proplists:get_value(queue, Source)),
     CArgs = proplists:get_value(consumer_args, Source, []),
@@ -77,7 +74,6 @@ parse(_Name, {source, Source}) ->
       resource_decl => rabbit_shovel_util:decl_fun(?MODULE, {source, Source}),
       queue => Queue,
       delete_after => proplists:get_value(delete_after, Source, never),
-      prefetch_count => Prefetch,
       consumer_args => CArgs};
 parse(_Name, {destination, Dest}) ->
     Exchange = parse_parameter(dest_exchange, fun parse_binary/1,

deps/rabbitmq_shovel/src/rabbit_shovel_parameters.erl

@@ -174,7 +174,6 @@ local_src_validation(_Def, User) ->
      {<<"src-queue">>, fun rabbit_parameter_validation:binary/2, optional},
      {<<"src-queue-args">>,   fun validate_queue_args/2, optional},
      {<<"src-consumer-args">>, fun validate_consumer_args/2, optional},
-     {<<"src-prefetch-count">>, fun rabbit_parameter_validation:number/2, optional},
      {<<"src-delete-after">>, fun validate_delete_after/2, optional},
      {<<"src-predeclared">>,  fun rabbit_parameter_validation:boolean/2, optional}
     ].
@@ -602,8 +601,6 @@ parse_local_source(Def) ->
     end,
     DeleteAfter = pget(<<"src-delete-after">>, Def,
                        pget(<<"delete-after">>, Def, <<"never">>)),
-    PrefetchCount = pget(<<"src-prefetch-count">>, Def,
-                         pget(<<"prefetch-count">>, Def, 1000)),
     %% Details are only used for status report in rabbitmqctl, as vhost is not
     %% available to query the runtime parameters.
     Details = maps:from_list([{K, V} || {K, V} <- [{exchange, SrcX},
@@ -614,7 +611,6 @@ parse_local_source(Def) ->
                   resource_decl => SrcDeclFun,
                   queue => Queue,
                   delete_after => opt_b2a(DeleteAfter),
-                  prefetch_count => PrefetchCount,
                   consumer_args => SrcCArgs
                  }, Details), DestHeaders}.