fix messaging bus

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

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

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
       )