Add fix to make AMQP reconnect on any disconnect.

FarmBot · Mar 5, 2019 · f69206c · f69206c
1 parent 466ead5
commit f69206c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/farmbot/bot_state/transport/amqp/amqp.ex b/lib/farmbot/bot_state/transport/amqp/amqp.ex
@@ -341,6 +341,8 @@ defmodule Farmbot.BotState.Transport.AMQP do
          {:ok, _tag}  <- Basic.consume(chan, q_base <> "_auto_sync", self(), [no_ack: true]),
          {:ok, _tag}  <- Basic.consume(chan, q_base <> "_nerves_hub", self(), [])
          do
+          Process.link(conn.pid)
+          Process.link(chan.pid)
           %State{conn: conn, chan: chan, bot: device}
     end
   end