From 0a3d63317b75d742372be8fb46e33bbd47752ca5 Mon Sep 17 00:00:00 2001 From: HaimKortovich Date: Thu, 16 Apr 2026 16:35:43 -0500 Subject: [PATCH] fix messaging bus --- lib/policy_service/handlers/quote_request_handler.ex | 2 +- lib/policy_service/handlers/solicitation_request_handler.ex | 2 +- lib/policy_service/message_bus.ex | 6 +++--- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/lib/policy_service/handlers/quote_request_handler.ex b/lib/policy_service/handlers/quote_request_handler.ex index bf2ceae..1e27513 100644 --- a/lib/policy_service/handlers/quote_request_handler.ex +++ b/lib/policy_service/handlers/quote_request_handler.ex @@ -6,6 +6,6 @@ defmodule PolicyService.Handlers.QuoteRequestHandler do alias PolicyService.Events.Policy.QuoteRequestSent def handle(%QuoteRequestSent{} = e, _metadata) do - PolicyService.MessageBus.publish("quote.requested", e) + PolicyService.MessageBus.publish("policy_service.events.quote_received", "quote.requested", e) end end diff --git a/lib/policy_service/handlers/solicitation_request_handler.ex b/lib/policy_service/handlers/solicitation_request_handler.ex index 9c9ae25..8d489fb 100644 --- a/lib/policy_service/handlers/solicitation_request_handler.ex +++ b/lib/policy_service/handlers/solicitation_request_handler.ex @@ -9,7 +9,7 @@ defmodule PolicyService.Handlers.SolicitationRequestHandler do alias PolicyService.MessageBus def handle(%QuoteAccepted{} = event, _metadata) do - MessageBus.publish("quote.accepted", event) + MessageBus.publish("policy_service.events.policy_issued", "quote.accepted", event) :ok end end diff --git a/lib/policy_service/message_bus.ex b/lib/policy_service/message_bus.ex index 3d182ec..bc45139 100644 --- a/lib/policy_service/message_bus.ex +++ b/lib/policy_service/message_bus.ex @@ -1,11 +1,11 @@ defmodule PolicyService.MessageBus do use AMQP - def publish(routing_key, event) do + def publish(exchange, routing_key, event) do payload = Jason.encode!(event) :ok = - AMQP.Basic.publish(channel(), "policy_service.events", routing_key, payload, + AMQP.Basic.publish(channel(), exchange, routing_key, payload, content_type: "application/json", persistent: true ) @@ -18,4 +18,4 @@ defmodule PolicyService.MessageBus do end defp amqp_url, do: Application.fetch_env!(:policy_service, :amqp_url) -end +end \ No newline at end of file