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

consume returns ok
All checks were successful
Build and Publish / build-release (push) Successful in 1m22s
Details

Browse Source
This commit is contained in:
HaimKortovich
2026-04-20 15:50:13 -05:00
parent 2fac2306e4
commit 089e8fc900
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

@@ -16,10 +16,13 @@ defmodule PolicyService.Consumers.QuoteTaskConsumer do
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))
{:ok, channel} = AMQP.Channel.open(conn) {:ok, channel} = AMQP.Channel.open(conn)
AMQP.Queue.declare(channel, @queue, durable: true) AMQP.Queue.declare(channel, @queue, durable: true)
AMQP.Queue.bind(channel, @queue, @exchange, routing_key: @routing_key) 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}") Logger.info("QuoteTaskConsumer started, listening on #{@queue}")
{:ok, %{channel: channel}} {:ok, %{channel: channel}}
end end