Shovel amqp1.0: fix delete after validation

Queue-length is not supported, so it should fail already during validation and
not shovel startup

(cherry picked from commit b6d831b)

# Conflicts:
#	deps/rabbitmq_shovel/src/rabbit_shovel_parameters.erl
#	deps/rabbitmq_shovel/test/amqp10_dynamic_SUITE.erl

Author: dcorbacho

deps/rabbitmq_shovel/src/rabbit_shovel_parameters.erl

@@ -133,7 +133,7 @@ amqp10_src_validation(_Def, User) ->
      {<<"src-uri">>, validate_uri_fun(User), mandatory},
      {<<"src-address">>, fun rabbit_parameter_validation:binary/2, mandatory},
      {<<"src-prefetch-count">>, fun rabbit_parameter_validation:number/2, optional},
-     {<<"src-delete-after">>, fun validate_delete_after/2, optional}
+     {<<"src-delete-after">>, fun validate_amqp10_delete_after/2, optional}
     ].
 
 amqp091_src_validation(_Def, User) ->
@@ -233,6 +233,23 @@ validate_delete_after(Name,  Term) ->
     {error, "~ts should be a number greater than or equal to 0, \"never\" or \"queue-length\", actually was "
      "~tp", [Name, Term]}.
 
+<<<<<<< HEAD
+=======
+validate_amqp10_delete_after(_Name, <<"never">>)          -> ok;
+validate_amqp10_delete_after(_Name, N) when is_integer(N), N >= 0 -> ok;
+validate_amqp10_delete_after(Name,  Term) ->
+    {error, "~ts should be a number greater than or equal to 0 or \"never\", actually was "
+     "~tp", [Name, Term]}.
+
+validate_internal_owner(Name, Term0) ->
+    Term = rabbit_data_coercion:to_proplist(Term0),
+
+    rabbit_parameter_validation:proplist(Name, [{<<"name">>, fun rabbit_parameter_validation:binary/2},
+                                                {<<"kind">>, rabbit_parameter_validation:enum(
+                                                              ['exchange', 'queue'])},
+                                                {<<"virtual_host">>, fun rabbit_parameter_validation:binary/2}], Term).
+
+>>>>>>> b6d831b11 (Shovel amqp1.0: fix delete after validation)
 validate_queue_args(Name, Term0) ->
     Term = rabbit_data_coercion:to_proplist(Term0),
 

deps/rabbitmq_shovel/test/amqp10_dynamic_SUITE.erl

@@ -28,7 +28,13 @@ groups() ->
           autodelete_amqp091_dest_on_publish,
           simple_amqp10_dest,
           simple_amqp10_src,
+<<<<<<< HEAD
           amqp091_to_amqp10_with_dead_lettering
+=======
+          amqp091_to_amqp10_with_dead_lettering,
+          amqp10_to_amqp091_application_properties,
+          test_amqp10_delete_after_queue_length
+>>>>>>> b6d831b11 (Shovel amqp1.0: fix delete after validation)
         ]},
       {with_map_config, [], [
           simple,
@@ -301,6 +307,25 @@ autodelete_amqp091_dest(Config, {AckMode, After, ExpSrc, ExpDest}) ->
             expect_count(Session, Src, <<"hello">>, ExpSrc)
     end.
 
+test_amqp10_delete_after_queue_length(Config) ->
+    Src = ?config(srcq, Config),
+    Dest = ?config(destq, Config),
+    Uri = shovel_test_utils:make_uri(Config, 0),
+    Error = rabbit_ct_broker_helpers:rpc(
+              Config, 0,
+              rabbit_runtime_parameters, set,
+              [<<"/">>, <<"shovel">>, <<"test">>, [{<<"src-uri">>,  Uri},
+                                                   {<<"dest-uri">>, [Uri]},
+                                                   {<<"src-protocol">>, <<"amqp10">>},
+                                                   {<<"src-address">>, Src},
+                                                   {<<"src-delete-after">>, <<"queue-length">>},
+                                                   {<<"dest-protocol">>, <<"amqp10">>},
+                                                   {<<"dest-address">>, Dest}],
+               none]),
+    ?assertMatch({error_string, _}, Error),
+    {_, Msg} = Error,
+    ?assertMatch(match, re:run(Msg, "Validation failed.*", [{capture, none}])).
+
 %%----------------------------------------------------------------------------
 
 with_session(Config, Fun) ->