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: handle_call({consume, ?QUEUE_ID_ASYNC_DELETION, MessageBin}) ->
      case catch binary_to_term(MessageBin) of
          {'EXIT', Cause} ->
              ?error("handle_call/1 - QUEUE_ID_ASYNC_DELETION", "cause:~p", [Cause]),
              {error, Cause};
          #async_deletion_message{addr_id  = AddrId,
                                  key      = Key} ->
  