anchor.diff:                                              {line, ?LINE}, {body, Cause}]),
                       {error, Cause}
               end,
  -    {reply, Reply, State, ?DEF_TIMEOUT};
  +    {reply, Reply, State};
   
   handle_call(peek, _From, #state{backend_db_id = BackendDbId} = State) ->
       Reply = case catch leo_backend_db_server:first(BackendDbId) of
  
positive.code:                                                         "_message_",
                                                          integer_to_list(SeqNum)
                                                         ])),
                          mq_properties = MQProps}, ?DEF_TIMEOUT}
      end.
  
  
  
negative.code:                                             {line, ?LINE}, {body, Why}]),
                      {error, Why}
              end,
      {reply, Reply, State};
  
  handle_call({has_key, KeyBin}, _From, #state{backend_db_id = BackendDbId} = State) ->
      Reply = case catch leo_backend_db_server:get(BackendDbId, KeyBin) of
  