From 30d95f18e1c69a38750616e2fea37af13014e3b7 Mon Sep 17 00:00:00 2001 From: HaimKortovich Date: Tue, 21 Apr 2026 11:55:06 -0500 Subject: [PATCH] change queue name --- lib/policy_service/consumers/quote_task_consumer.ex | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/lib/policy_service/consumers/quote_task_consumer.ex b/lib/policy_service/consumers/quote_task_consumer.ex index 17287cc..b8580cd 100644 --- a/lib/policy_service/consumers/quote_task_consumer.ex +++ b/lib/policy_service/consumers/quote_task_consumer.ex @@ -8,10 +8,12 @@ defmodule PolicyService.Consumers.QuoteTaskConsumer do alias PolicyService.Aggregates.PolicyId @exchange "workload_service.events.quote_task_completed" - @queue "policy_service.quote_task_consumer" + @queue "policy_service.quote_task_completed" @routing_key "quote_task.completed" - def start_link(opts \\ []), do: GenServer.start_link(__MODULE__, opts, name: __MODULE__) + def start_link(opts \\ []) do + GenServer.start_link(__MODULE__, opts, name: __MODULE__) + end def init(_opts) do {:ok, conn} = AMQP.Connection.open(Application.fetch_env!(:policy_service, :amqp_url))