     jwt = Keyword.fetch!(args, :jwt)
     http_ping_timer = Process.send_after(self(), :http_ping, 5000)
 
+    _ = Leds.blue(:off)
+
     state = %State{
       conn: nil,
       chan: nil,

  def terminate(reason, state) do
    FarmbotCore.Logger.error(1, "Disconnected from PingPong channel: #{inspect(reason)}")
    # If a channel was still open, close it.
    if state.chan, do: ConnectionWorker.close_channel(state.chan)
  end


         :ok <- Queue.bind(chan, ping, @exchange, routing_key: route <> ".#"),
         {:ok, _tag} <- Basic.consume(chan, ping, self(), no_ack: true) do
      FarmbotCore.Logger.debug(3, "connected to PingPong channel")
      _ = Leds.blue(:solid)
      {:noreply, %{state | conn: conn, chan: chan}}
    else
      nil ->
