diff --git a/lib/clients/adapter.ex b/lib/clients/adapter.ex index baac58e..b877ae8 100644 --- a/lib/clients/adapter.ex +++ b/lib/clients/adapter.ex @@ -9,14 +9,15 @@ defmodule ExRabbitPool.Clients.Adapter do {:ok, String.t()} | AMQP.Basic.error() @callback cancel_consume(AMQP.Channel.t(), String.t(), keyword) :: {:ok, String.t()} | {:error, AMQP.Basic.error()} - @callback ack(AMQP.Channel.t(), String.t(), keyword()) :: :ok | AMQP.Basic.error() - @callback reject(AMQP.Channel.t(), String.t(), keyword()) :: :ok | AMQP.Basic.error() + @callback ack(AMQP.Channel.t(), AMQP.Basic.delivery_tag(), keyword()) :: + :ok | AMQP.Basic.error() + @callback reject(AMQP.Channel.t(), AMQP.Basic.delivery_tag(), keyword()) :: + :ok | AMQP.Basic.error() @callback declare_queue(AMQP.Channel.t(), AMQP.Basic.queue(), keyword()) :: {:ok, map()} | AMQP.Basic.error() @callback queue_bind(AMQP.Channel.t(), AMQP.Basic.queue(), AMQP.Basic.exchange(), keyword()) :: :ok | AMQP.Basic.error() @callback declare_exchange(AMQP.Channel.t(), AMQP.Basic.exchange(), keyword()) :: :ok | AMQP.Basic.error() - @callback qos(AMQP.Channel.t(), keyword()) :: - :ok | AMQP.Basic.error() + @callback qos(AMQP.Channel.t(), keyword()) :: :ok | AMQP.Basic.error() end diff --git a/lib/clients/fake_rabbitmq.ex b/lib/clients/fake_rabbitmq.ex index be1a533..1f76787 100644 --- a/lib/clients/fake_rabbitmq.ex +++ b/lib/clients/fake_rabbitmq.ex @@ -24,12 +24,12 @@ defmodule ExRabbitPool.FakeRabbitMQ do end @impl true - def ack(_channel, _tag, _options \\ []) do + def ack(_channel, _delivery_tag, _options \\ []) do :ok end @impl true - def reject(_channel, _tag, _options \\ []) do + def reject(_channel, _delivery_tag, _options \\ []) do :ok end diff --git a/lib/clients/rabbitmq.ex b/lib/clients/rabbitmq.ex index b4c7f17..6470963 100644 --- a/lib/clients/rabbitmq.ex +++ b/lib/clients/rabbitmq.ex @@ -21,13 +21,13 @@ defmodule ExRabbitPool.RabbitMQ do end @impl true - def ack(%Channel{} = channel, tag, options \\ []) do - Basic.ack(channel, tag, options) + def ack(%Channel{} = channel, delivery_tag, options \\ []) do + Basic.ack(channel, delivery_tag, options) end @impl true - def reject(%Channel{} = channel, tag, options \\ []) do - Basic.reject(channel, tag, options) + def reject(%Channel{} = channel, delivery_tag, options \\ []) do + Basic.reject(channel, delivery_tag, options) end @impl true diff --git a/lib/consumer.ex b/lib/consumer.ex index b7ee6fd..75ceb08 100644 --- a/lib/consumer.ex +++ b/lib/consumer.ex @@ -116,9 +116,6 @@ defmodule ExRabbitPool.Consumer do {:stop, reason} -> {:stop, reason, state} - - _ -> - {:noreply, state} end end @@ -133,9 +130,6 @@ defmodule ExRabbitPool.Consumer do {:stop, reason} -> {:stop, reason, state} - - _ -> - {:noreply, state} end end