From 20b20a9a18b07402d94404382d6b8a209149c05f Mon Sep 17 00:00:00 2001 From: Tatsuya Ono Date: Mon, 8 Mar 2021 18:50:38 +0000 Subject: [PATCH] doc tweak --- lib/amqp/application.ex | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/lib/amqp/application.ex b/lib/amqp/application.ex index 6678540..5b30514 100644 --- a/lib/amqp/application.ex +++ b/lib/amqp/application.ex @@ -210,13 +210,17 @@ defmodule AMQP.Application do .... def handle_info(:subscribe, state) do - subscribe() - {:noreply, state} + case subscribe() do + {:ok, chan} -> + {:noreply, Map.put(state, :channel, chan)} + _ -> + {:noreply, state} + end end - def handle_info({:DOWN, _, :process, pid, reason}, state) do + def handle_info({:DOWN, _, :process, pid, reason}, %{channel: %{pid: pid}} = state) do send(self(), :subscribe) - {:noreply, state} + {:noreply, Map.put(state, :channel, nil)} end defp subscribe() do