anchor.diff:                      ok;
                   {error, not_found} ->
                       ok;
  -                Error ->
  +                {error, Cause} ->
                       publish(?QUEUE_TYPE_PER_OBJECT, AddrId, Key, ErrorType),
  -                    Error
  +                    ?warn("handle_call/1 - QUEUE_ID_PER_OBJECT", "cause:~p", [Cause]),
  +                    {error, Cause}
               end
       end;
   
   handle_call({consume, ?QUEUE_ID_SYNC_BY_VNODE_ID, MessageBin}) ->
       case catch binary_to_term(MessageBin) of
           {'EXIT', Cause} ->
  +            ?error("handle_call/1 - QUEUE_ID_SYNC_BY_VNODE_ID", "cause:~p", [Cause]),
               {error, Cause};
           #sync_unit_of_vnode_message{vnode_id = ToVNodeId,
                                       node     = Node} ->
  
positive.code: handle_call({consume, ?QUEUE_ID_ASYNC_DELETION, MessageBin}) ->
      case catch binary_to_term(MessageBin) of
          {'EXIT', Cause} ->
              {error, Cause};
          #async_deletion_message{addr_id  = AddrId,
                                  key      = Key} ->
  
negative.code: handle_call({consume, ?QUEUE_ID_REBALANCE, MessageBin}) ->
      case catch binary_to_term(MessageBin) of
          {'EXIT', Cause} ->
              ?error("handle_call/1 - QUEUE_ID_REBALANCE", "cause:~p", [Cause]),
              {error, Cause};
          #rebalance_message{node     = Node,
                             vnode_id = VNodeId,
  