anchor.diff:  
   init([TransportPid]) ->
       chloe_channel_store:subscribe("/all", self()),
  -    {ok, #state{transport_pid = TransportPid, messages = []}}.
  +    {ok, #state{transport_pid = TransportPid, messages = [], failed_health_checks = 0}, ?TIMEOUT}.
   
   handle_call(retrieve_messages, _From, State) ->
       Messages = State#state.messages,
       error_logger:info_msg("Old State was ~p~n", [State]),
       NewState = State#state{messages= [] },
       error_logger:info_msg("New State is ~p~n", [NewState]),
  -    {reply, Messages, NewState};
  +    {reply, Messages, NewState, ?TIMEOUT};
   handle_call(_Request, _From, State) ->
  -    {reply, ok, State}.
  +    {reply, ok, State, ?TIMEOUT}.
   
   handle_cast({send_to_server, Data}, State) ->
       send_data_to_server(Data),
  -    {noreply, State};
  +    {noreply, State, ?TIMEOUT};
   handle_cast({subscribe, Channel}, State) ->
       error_logger:info_msg("Subscribing to channel ~p~n", [Channel]),
       chloe_channel_store:subscribe(Channel, self()),
  -    {noreply, State};
  +    {noreply, State, ?TIMEOUT};
   handle_cast({send_to_browser, [Channel, Data]}, State) ->
       %% TODO (trotter): Handle case where we have a pid but
       %%                 it's no longer active.
  
positive.code:         _  -> NewState = State#state{messages = []},
                gen_server:cast(TransportPid, {send, [Messages]})
      end,
      {noreply, NewState#state{transport_pid = TransportPid}}.
  
  handle_info(_Info, State) ->
      {noreply, State}.
  
  terminate(_Reason, _State) ->
      ok.
  
negative.code: %%--------------------------------------------------------------------
  %% Internal Functions
  %%--------------------------------------------------------------------
  
  check_transport_health(State) ->
      case is_transport_available(State#state.transport_pid) of
          true -> ok;
          _ -> case State#state.failed_health_checks > ?HEALTH_CHECK_THRESHOLD of
                  true  -> dead;
                  _     -> unhealthy
               end
      end.
  
  send_data_to_server(Data) ->
      {ok, Url} = application:get_env(chloe, application_server_url),
  