diff --git a/lib/policy_service/consumers/quote_task_consumer.ex b/lib/policy_service/consumers/quote_task_consumer.ex
index 475a675..17287cc 100644
--- a/lib/policy_service/consumers/quote_task_consumer.ex
+++ b/lib/policy_service/consumers/quote_task_consumer.ex
@@ -16,10 +16,13 @@ defmodule PolicyService.Consumers.QuoteTaskConsumer do
   def init(_opts) do
     {:ok, conn} = AMQP.Connection.open(Application.fetch_env!(:policy_service, :amqp_url))
     {:ok, channel} = AMQP.Channel.open(conn)
+
     AMQP.Queue.declare(channel, @queue, durable: true)
     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}")
+
     {:ok, %{channel: channel}}
   end