     if state.chan, do: ConnectionWorker.close_channel(state.chan)
   end
 
-  def handle_info(:timeout, state) do
+  def handle_info(:connect_amqp, state) do
     bot = state.jwt.bot
     ping = bot <> "_ping"
     route = "bot.#{bot}.ping"

      {:noreply, %{state | conn: conn, chan: chan}}
    else
      nil ->
        {:noreply, %{state | conn: nil, chan: nil}, 5000}

      err ->
        FarmbotCore.Logger.error(1, "Failed to connect to PingPong channel: #{inspect(err)}")
        {:noreply, %{state | conn: nil, chan: nil}, 1000}
    end
  end


      ping_fails: 0
    }

    {:ok, state}
  end

  def terminate(reason, state) do
