diff --git a/lib/pigeon/dispatcher_worker.ex b/lib/pigeon/dispatcher_worker.ex index bef82f1..3528061 100644 --- a/lib/pigeon/dispatcher_worker.ex +++ b/lib/pigeon/dispatcher_worker.ex @@ -40,7 +40,7 @@ defmodule Pigeon.DispatcherWorker do {:noreply, %{adapter: adapter, state: new_state}} {:stop, reason} -> - {:shutdown, reason, %{adapter: adapter, state: state}} + {:stop, {:shutdown, reason, %{adapter: adapter, state: state}}} {:stop, reason, new_state} -> {:stop, reason, %{adapter: adapter, state: new_state}}