anchor.diff:  update_timeout_metrics(Id) ->
       lager:error("unknown iq id ~p", Id).
   
  -schedule_publishing(SchedulingPolicy) ->
  -    case get_parameter(scheduling_policy) of
  -        SchedulingPolicy ->
  -            DelayBetweenMessages = get_parameter(publication_delay),
  -            erlang:send_after(DelayBetweenMessages, self(), publish_item);
  -        _ -> ok
  -    end.
  -
  +schedule_publishing(Pid) ->
  +    throttle:send(?PUBLICATION_THROTTLING, Pid, publish_item).
   
   %%------------------------------------------------------------------------------------------------
   %% User connection
  
positive.code: -spec init() -> {ok, amoc_scenario:state()} | {error, Reason :: term()}.
  init() ->
      init_metrics(),
      config:get_scenario_settings(?ALL_PARAMETERS).
  
  -spec start(amoc_scenario:user_id(), amoc_scenario:state()) -> any().
  start(Id, Settings) ->
  
negative.code: activate_users(Pids, ActivationPolicy) ->
      case get_parameter(activation_policy) of
          ActivationPolicy ->
              [schedule_publishing(Pid)||Pid<-Pids];
          _ -> ok
      end.
  
  get_coordinator_pid() ->
      case pg2:get_members(?GROUP_NAME) of
  