diff --git a/lib/tackle/consumer.ex b/lib/tackle/consumer.ex index 3fbb14c..e91528e 100644 --- a/lib/tackle/consumer.ex +++ b/lib/tackle/consumer.ex @@ -92,7 +92,7 @@ defmodule Tackle.Consumer do AMQP.Basic.nack(state.channel, tag, [multiple: false, requeue: false]) end - spawn(fn-> delivery_handler(consume_callback, error_callback) end) + spawn_link(fn-> delivery_handler(consume_callback, error_callback) end) {:noreply, state} end