diff --git a/lib/policy_service/consumers/quote_task_consumer.ex b/lib/policy_service/consumers/quote_task_consumer.ex index b8580cd..96af53a 100644 --- a/lib/policy_service/consumers/quote_task_consumer.ex +++ b/lib/policy_service/consumers/quote_task_consumer.ex @@ -30,9 +30,12 @@ defmodule PolicyService.Consumers.QuoteTaskConsumer do def handle_info({:basic_deliver, payload, %{delivery_tag: tag}}, %{channel: ch} = state) do with {:ok, event} <- Jason.decode(payload), - {:ok, _} <- dispatch(event) do + :ok <- dispatch(event) do AMQP.Basic.ack(ch, tag) else + {:ok, _} -> + AMQP.Basic.ack(ch, tag) + {:error, reason} -> Logger.error("QuoteTaskConsumer failed: #{inspect(reason)}") AMQP.Basic.nack(ch, tag, requeue: false)