anchor.diff:  -spec(publish(queue_type(), atom()) ->
                ok).
   publish(?QUEUE_TYPE_RECOVERY_NODE = Id, Node) ->
  -    KeyBin     = term_to_binary(Node),
  -    MessageBin = term_to_binary(
  -                   #recovery_node_message{id        = leo_date:clock(),
  -                                          node      = Node,
  -                                          timestamp = leo_date:now()}),
  -    leo_mq_api:publish(queue_id(Id), KeyBin, MessageBin);
  +    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}.
   
  
positive.code:         _ ->
              {error, ?ERROR_COULD_MATCH}
      end.
  
  
  %%--------------------------------------------------------------------
  
negative.code:     ?QUEUE_ID_SYNC_OBJ_WITH_DC;
  queue_id(?QUEUE_TYPE_COMP_META_WITH_DC) ->
      ?QUEUE_ID_COMP_META_WITH_DC.
  