anchor.diff:      ?QUEUE_ID_SYNC_OBJ_WITH_DC;
   queue_id(?QUEUE_TYPE_COMP_META_WITH_DC) ->
       ?QUEUE_ID_COMP_META_WITH_DC.
  -
  
positive.code: 
  -export([start/2, start/3,
           publish/2, publish/3, publish/4, publish/5]).
  -export([init/0, handle_call/1]).
  
  -define(SLASH, "/").
  -define(MSG_PATH_PER_OBJECT,        "1").
  
negative.code: -spec(publish(queue_type(), atom()) ->
               ok).
  publish(?QUEUE_TYPE_RECOVERY_NODE = Id, Node) ->
      KeyBin = term_to_binary(Node),
      MsgBin = term_to_binary(
                 #recovery_node_message{id        = leo_date:clock(),
                                        node      = Node,
                                        timestamp = leo_date:now()}),
      leo_mq_api:publish(queue_id(Id), KeyBin, MsgBin);
  publish(_,_) ->
      {error, badarg}.
  
  