anchor.diff:  
           {add_users, MemberJids} ->
               add_users_to_room(Client, MemberJids),
  -            user_loop(Client, Time)
  +            user_loop(Client, Time);
  +        remove_user ->
  +            lager:debug("Removing myself ~p", [self()]),
  +            remove_self(Client)
       end.
   
   
   schedule_publishing(Pid) ->
       amoc_throttle:send(?PUBLICATION_THROTTLING, Pid, publish_item).
  +
  +schedule_removal(Pid) ->
  +    amoc_throttle:send(?REMOVAL_THROTTLING, Pid, remove_user).
   
   update_publication_interval(0, _Now) ->
       ok;
  
positive.code: update_message_ttd(Time, Now) ->
      Interval = Now - Time,
      amoc_metrics:update_time(message_ttd, Interval).
  
  %%------------------------------------------------------------------------------------------------
  %% User connection
  
negative.code: activate_users(Pids, ActivationPolicy) ->
      case get_parameter(activation_policy) of
          ActivationPolicy ->
              [begin
                   schedule_publishing(Pid),
                   schedule_removal(Pid)
               end || Pid<-Pids];
          _ -> ok
      end.
  
  %%------------------------------------------------------------------------------------------------
  