diff --git a/lib/policy_service/consumers/quote_task_consumer.ex b/lib/policy_service/consumers/quote_task_consumer.ex
index 17287cc..b8580cd 100644
--- a/lib/policy_service/consumers/quote_task_consumer.ex
+++ b/lib/policy_service/consumers/quote_task_consumer.ex
@@ -8,10 +8,12 @@ defmodule PolicyService.Consumers.QuoteTaskConsumer do
   alias PolicyService.Aggregates.PolicyId
 
   @exchange "workload_service.events.quote_task_completed"
-  @queue "policy_service.quote_task_consumer"
+  @queue "policy_service.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
     {:ok, conn} = AMQP.Connection.open(Application.fetch_env!(:policy_service, :amqp_url))