   def init({%Context{} = context, %Token{} = token}) do
     Logger.info ">> Starting mqtt!", type: :busy
     Process.flag(:trap_exit, true)
-    {:ok, %{token: token, context: context, cs_nodes: [], throttle: 0}}
+    {:ok, %{token: token, context: context, cs_nodes: []}}
   end
 
   def on_connect(%{token: token, context: context} = state) do
     GenMQTT.subscribe(self(), [{bot_topic(token), 0}])
-    Process.send_after(self(), :throttle_timeout, 1000)
 
     fn ->
       Process.sleep(10)

    json = Poison.encode! msg
    GenMQTT.publish(self(), frontend_topic(state.token), json, 0, false)
    {:noreply, state}
  end

  def handle_info(:throttle_timeout, state) do
    debug_log "resetting throttle count"
    # spawn fn() -> Farmbot.Transport.force_state_push(state.context) end
    Process.send_after(self(), :throttle_timeout, 1000)
    {:ok, %{state | throttle: 0}}
  end

  def handle_info({:EXIT, pid, _reason}, state) do

  alias   Farmbot.{Context, Token}
  use     Farmbot.DebugLog, name: MqttClient
  use     GenMQTT

  @doc """
    Starts a mqtt client.
