anchor.diff:      user_loop(Settings, Client, #{}).
   
   create_new_node(Client, Settings) ->
  -    Coordinator = get_coordinator_pid(),
       amoc_throttle:send_and_wait(?NODE_CREATION_THROTTLING, create_node),
       create_pubsub_node(Client, Settings),
  -    Coordinator ! {new_client, self(), Client}.
  +    amoc_coordinator:add(?MODULE, Client).
   
   user_loop(Settings, Client, Requests) ->
       IqTimeout = get_parameter(iq_timeout, Settings),
  
positive.code: 
              amoc_throttle:start(?NODE_CREATION_THROTTLING, NodeCreationRate),
              amoc_throttle:start(?PUBLICATION_THROTTLING, PublicationRate),
              {ok, Settings};
          Error -> Error
      end.
  
negative.code: -define(NODE_CREATION_THROTTLING, node_creation).
  -define(PUBLICATION_THROTTLING, publication).
  
  -define(COORDINATOR_TIMEOUT, 100).
  
  -export([init/0, start/2]).
  
  