software-engineering/policy-service
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix pattern match
All checks were successful
Build and Publish / build-release (push) Successful in 1m23s
Details

Browse Source
This commit is contained in:
HaimKortovich
2026-04-21 15:13:20 -05:00
parent a5e3e1140e
commit dd2e25e86a
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
lib/policy_service/consumers/quote_task_consumer.ex
View File

@@ -30,9 +30,12 @@ defmodule PolicyService.Consumers.QuoteTaskConsumer do
def handle_info({:basic_deliver, payload, %{delivery_tag: tag}}, %{channel: ch} = state) do def handle_info({:basic_deliver, payload, %{delivery_tag: tag}}, %{channel: ch} = state) do
with {:ok, event} <- Jason.decode(payload), with {:ok, event} <- Jason.decode(payload),
{:ok, _} <- dispatch(event) do :ok <- dispatch(event) do
AMQP.Basic.ack(ch, tag) AMQP.Basic.ack(ch, tag)
else else
{:ok, _} ->
AMQP.Basic.ack(ch, tag)
{:error, reason} -> {:error, reason} ->
Logger.error("QuoteTaskConsumer failed: #{inspect(reason)}") Logger.error("QuoteTaskConsumer failed: #{inspect(reason)}")
AMQP.Basic.nack(ch, tag, requeue: false) AMQP.Basic.nack(ch, tag, requeue: false)