anchor.diff:  %%                                       {noreply, State, Timeout} |
   %%                                       {stop, Reason, State}
   %% @doc Handling all non call/cast messages
  -handle_info({'EXIT', Pid, restarting}, State=#state{twitter_pid=Pid}) ->
  -    ?DEBUG("Restarting"),
  +handle_info({'EXIT', _Pid, restarting}, #state{context=Context}=State) ->
       timer:sleep(500),
  -    {noreply, restart_http(State)};
  -
  -handle_info({'EXIT', Pid, {error, Reason}}, State=#state{twitter_pid=Pid}) ->
  -    ?DEBUG(Reason),
  +    Pid=start_following(Context),
  +    {noreply, State#state{twitter_pid=Pid}};
  +
  +handle_info({'EXIT', _Pid, {error, _Reason}}, #state{context=Context}=State) ->
       timer:sleep(15000),
  -    {noreply, restart_http(State)};
  +    Pid=start_following(Context),
  +    {noreply, State#state{twitter_pid=Pid}};
   
   handle_info(_Info, State) ->
  -    ?DEBUG(_Info),
       {noreply, State}.
   
  -restart_http(State=#state{context=Context}) ->
  -    NewPid = start_following(Context),
  -    State#state{twitter_pid=NewPid}.
  -    
   
   %% @spec terminate(Reason, State) -> void()
   %% @doc This function is called by a gen_server when it is about to
  
positive.code: 
      %% Listen to resource-change events
      z_notifier:observe(rsc_update_done,   {?MODULE, event}, Context),
  
      %% Start the twitter process
      Pid = start_following(Context),
  
      {ok, #state{context=z_context:new(Context), twitter_pid=Pid}}.
  
  %% @spec handle_call(Request, From, State) -> {reply, Reply, State} |
  %%                                      {reply, Reply, State, Timeout} |
  
negative.code: process_data(Data, Context) ->
      case Data of
          <<${, _/binary>> ->
              {struct, Tweet} = mochijson:decode(Data),
  
              AsyncContext = z_context:prune_for_async(Context),
              F = fun() ->
                          {struct, User} = proplists:get_value("user", Tweet),
                          TweeterId = proplists:get_value("id", User),
                          case m_identity:lookup_by_type_and_key("twitter_id", TweeterId, AsyncContext) of
                              undefined ->
                                  ?DEBUG("Unknown user..."),
                                  z_session_manager:broadcast(#broadcast{type="error", message="Received a tweet for an unknown user.", title="Unknown user", stay=false}, Context);
                              Row ->
                                  UserId = proplists:get_value(rsc_id, Row),
  
  