From 54a8c168bff506472aacdfd17fd95c27e2216166 Mon Sep 17 00:00:00 2001
From: HaimKortovich <haimkortovich88@gmail.com>
Date: Thu, 16 Apr 2026 17:01:39 -0500
Subject: [PATCH] fix exchanges

---
 .../consumers/quote_requested_consumer.ex     | 20 ++++++------
 ops/chart/values.yaml                         | 32 +------------------
 2 files changed, 12 insertions(+), 40 deletions(-)

diff --git a/lib/workload_service/consumers/quote_requested_consumer.ex b/lib/workload_service/consumers/quote_requested_consumer.ex
index 79f91fe..da03256 100644
--- a/lib/workload_service/consumers/quote_requested_consumer.ex
+++ b/lib/workload_service/consumers/quote_requested_consumer.ex
@@ -5,8 +5,8 @@ defmodule WorkloadService.Consumers.QuoteRequestedConsumer do
   alias WorkloadService.CommandedApp
   alias WorkloadService.Commands.QuoteTask
 
-  @exchange "workload_service.events.quote_requested"
-  @queue "workload_service.quote_requested"
+  @exchange "policy_service.events.quote_requested"
+  @queue "policy_service.quote_requested"
   @routing_key "quote.requested"
 
   def start_link(opts \\ []) do
@@ -50,12 +50,14 @@ defmodule WorkloadService.Consumers.QuoteRequestedConsumer do
     end
   end
 
-  defp handle_event(%{
-    "application_id" => application_id,
-    "org_id" => org_id,
-    "provider_id" => provider_id,
-    "policy_type" => policy_type
-  } = event) do
+  defp handle_event(
+         %{
+           "application_id" => application_id,
+           "org_id" => org_id,
+           "provider_id" => provider_id,
+           "policy_type" => policy_type
+         } = event
+       ) do
     task_id = WorkloadService.Aggregates.TaskId.new(org_id, "quote", Ecto.UUID.generate())
 
     command = %QuoteTask.CreateTask{
@@ -90,4 +92,4 @@ defmodule WorkloadService.Consumers.QuoteRequestedConsumer do
   defp amqp_url do
     Application.get_env(:workload_service, :amqp_url, "amqp://guest:guest@localhost:5672")
   end
-end
\ No newline at end of file
+end
diff --git a/ops/chart/values.yaml b/ops/chart/values.yaml
index 3edcb27..0e446ef 100644
--- a/ops/chart/values.yaml
+++ b/ops/chart/values.yaml
@@ -140,36 +140,6 @@ rawResources:
           configure: ".*"
           read: ".*"
 
-  exchange-quote-requested:
-    enabled: true
-    apiVersion: rabbitmq.com/v1beta1
-    kind: Exchange
-    suffix: exchange-quote-requested
-    spec:
-      spec:
-        name: workload_service.events.quote_requested
-        type: topic
-        durable: true
-        vhost: "application"
-        rabbitmqClusterReference:
-          name: rabbitmq
-          namespace: rabbitmq
-
-  exchange-solicitation-requested:
-    enabled: true
-    apiVersion: rabbitmq.com/v1beta1
-    kind: Exchange
-    suffix: exchange-solicitation-requested
-    spec:
-      spec:
-        name: workload_service.events.solicitation_requested
-        type: topic
-        durable: true
-        vhost: "application"
-        rabbitmqClusterReference:
-          name: rabbitmq
-          namespace: rabbitmq
-
   exchange-task-completed:
     enabled: true
     apiVersion: rabbitmq.com/v1beta1
@@ -249,4 +219,4 @@ rawResources:
           name: '{{ include "bjw-s.common.lib.chart.names.fullname" $ }}-cluster-pg'
         schemas:
           - name: eventstore
-            owner: workload_service
\ No newline at end of file
+            owner: workload_service