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

change queue name
All checks were successful
Build and Publish / build-release (push) Successful in 1m35s
Details

Browse Source
This commit is contained in:
HaimKortovich
2026-04-21 11:55:06 -05:00
parent 089e8fc900
commit 30d95f18e1
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -8,10 +8,12 @@ defmodule PolicyService.Consumers.QuoteTaskConsumer do
alias PolicyService.Aggregates.PolicyId alias PolicyService.Aggregates.PolicyId
@exchange "workload_service.events.quote_task_completed" @exchange "workload_service.events.quote_task_completed"
@queue "policy_service.quote_task_consumer" @queue "policy_service.quote_task_completed"
@routing_key "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 def init(_opts) do
{:ok, conn} = AMQP.Connection.open(Application.fetch_env!(:policy_service, :amqp_url)) {:ok, conn} = AMQP.Connection.open(Application.fetch_env!(:policy_service, :amqp_url))