anchor.diff:      Intervals = ?env_mq_consumption_intervals(),
       ok = leo_storage_mq_client:start(Pid, Intervals, QueueDir),
   
  +    %% After processing
  +    ensure_started(rex, rpc, start_link, worker, 2000),
  +    ok = leo_storage_api:register_in_monitor(first),
  +
       %% Launch metric-servers
       ok = leo_statistics_api:start_link(leo_storage),
       ok = leo_statistics_api:create_tables(ram_copies, [node()]),
       ok = leo_metrics_vm:start_link(?SNMP_SYNC_INTERVAL_10S),
       ok = leo_metrics_req:start_link(?SNMP_SYNC_INTERVAL_60S),
       ok = leo_storage_statistics:start_link(?SNMP_SYNC_INTERVAL_10S),
  -
  -    %% After processing
  -    ensure_started(rex, rpc, start_link, worker, 2000),
  -    ok = leo_storage_api:register_in_monitor(first),
       {ok, Pid};
   
   after_proc(Error) ->
  
positive.code: %%----------------------------------------------------------------------
  %% INNER FUNCTION
  %%----------------------------------------------------------------------
  
  ensure_started(Id, Module, Method, Type, Timeout) ->
      case whereis(Id) of
          undefined ->
  
negative.code:         Pid -> Pid
      end.
  
  %% @private
  after_proc({ok, Pid}) ->
      ensure_started(inet_db, inet_db, start_link, worker, 2000),
      ensure_started(net_sup, erl_distribution, start_link, supervisor, infinity),
  