anchor.diff:  handle_call({consume, ?QUEUE_ID_PER_OBJECT, MessageBin}) ->
       case catch binary_to_term(MessageBin) of
           {'EXIT', Cause} ->
  +            ?error("handle_call/1 - QUEUE_ID_PER_OBJECT", "cause:~p", [Cause]),
               {error, Cause};
           #inconsistent_data_message{addr_id = AddrId,
                                      key     = Key,
  
positive.code: handle_call({consume, ?QUEUE_ID_REBALANCE, MessageBin}) ->
      case catch binary_to_term(MessageBin) of
          {'EXIT', Cause} ->
              {error, Cause};
          #rebalance_message{node     = Node,
                             vnode_id = VNodeId,
  
negative.code:                     ok;
                  {error, not_found} ->
                      ok;
                  {error, Cause} ->
                      publish(?QUEUE_TYPE_PER_OBJECT, AddrId, Key, ErrorType),
                      ?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} ->
  