Skip to content

Commit 179c879

Browse files
committed
issue #33: relax exchange argument type constraint
Signed-off-by: Matteo Cafasso <[email protected]>
1 parent 68597b9 commit 179c879

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/rabbit_message_deduplication_exchange.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ defmodule RabbitMQ.MessageDeduplicationPlugin.Exchange do
7979

8080
def validate(exchange(arguments: args)) do
8181
case List.keyfind(args, "x-cache-size", 0) do
82-
{"x-cache-size", :long, val} when val > 0 -> :ok
82+
{"x-cache-size", _, val} when is_integer(val) and val > 0 -> :ok
8383
{"x-cache-size", :longstr, val} ->
8484
case Integer.parse(val, 10) do
8585
:error -> RabbitMisc.protocol_error(
@@ -97,7 +97,7 @@ defmodule RabbitMQ.MessageDeduplicationPlugin.Exchange do
9797

9898
case List.keyfind(args, "x-cache-ttl", 0) do
9999
nil -> :ok
100-
{"x-cache-ttl", :long, val} when val > 0 -> :ok
100+
{"x-cache-ttl", _, val} when is_integer(val) and val > 0 -> :ok
101101
{"x-cache-ttl", :longstr, val} ->
102102
case Integer.parse(val, 10) do
103103
:error -> RabbitMisc.protocol_error(

0 commit comments

Comments
 (0)