anchor.diff:  
   %% @doc Replicate an object from local-node to remote node
   %% @private
  --spec(replicate_fun(replication(), request_verb(), integer(), #?OBJECT{}) ->
  +-spec(replicate_fun(replication(), request_verb(), integer(), #?OBJECT{}, atom()) ->
                {ok, ETag} | {error, any()} when ETag::{etag, integer()}).
  -replicate_fun(?REP_LOCAL, Method, AddrId, Object) ->
  +replicate_fun(?REP_LOCAL, Method, AddrId, Object, From) ->
       %% Check state of the node
       case leo_watchdog_state:find_not_safe_items(?WD_EXCLUDE_ITEMS) of
           not_found ->
               case leo_redundant_manager_api:get_redundancies_by_addr_id(put, AddrId) of
                   {ok, #redundancies{nodes = Redundancies,
  +                                   n = NumOfReplicas,
                                      w = WriteQuorum,
                                      d = DeleteQuorum,
                                      ring_hash = RingHash}} ->
  -                    Quorum = ?quorum(Method, WriteQuorum, DeleteQuorum),
  +                    Quorum = case From of
  +                                 leo_mq ->
  +                                     ?quorum(Method, NumOfReplicas, NumOfReplicas);
  +                                 _ ->
  +                                     ?quorum(Method, WriteQuorum, DeleteQuorum)
  +                             end,
                       leo_storage_replicator:replicate(
                         Method, Quorum, Redundancies,
                         Object#?OBJECT{ring_hash = RingHash},
  
positive.code: 
  -export([get/1, get/2, get/3, get/4, get/5,
           put/1, put/2, put/4,
           delete/1, delete/2, delete/3,
           delete_objects_under_dir/1,
           delete_objects_under_dir/2,
           delete_objects_under_dir/3,
  
negative.code:     Ret = replicate_fun(?REP_LOCAL, ?CMD_PUT, Object#?OBJECT.addr_id,
                          Object#?OBJECT{method = ?CMD_PUT,
                                         clock = leo_date:clock(),
                                         req_id = ReqId}, gateway),
      case Ret of
          {ok, _} ->
              ?access_log_put(Object#?OBJECT.key, Object#?OBJECT.dsize, ReqId, BeginTime, ok);
  