From 089e8fc9004f96301b2fea8201e9117b5801d228 Mon Sep 17 00:00:00 2001 From: HaimKortovich Date: Mon, 20 Apr 2026 15:50:13 -0500 Subject: [PATCH] consume returns ok --- lib/policy_service/consumers/quote_task_consumer.ex | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/lib/policy_service/consumers/quote_task_consumer.ex b/lib/policy_service/consumers/quote_task_consumer.ex index 475a675..17287cc 100644 --- a/lib/policy_service/consumers/quote_task_consumer.ex +++ b/lib/policy_service/consumers/quote_task_consumer.ex @@ -16,10 +16,13 @@ defmodule PolicyService.Consumers.QuoteTaskConsumer do def init(_opts) do {:ok, conn} = AMQP.Connection.open(Application.fetch_env!(:policy_service, :amqp_url)) {:ok, channel} = AMQP.Channel.open(conn) + AMQP.Queue.declare(channel, @queue, durable: true) AMQP.Queue.bind(channel, @queue, @exchange, routing_key: @routing_key) - AMQP.Basic.consume(channel, @queue, nil, no_ack: false) + {:ok, _tag} = AMQP.Basic.consume(channel, @queue) + Logger.info("QuoteTaskConsumer started, listening on #{@queue}") + {:ok, %{channel: channel}} end