anchor.diff:  
   %% @doc Close a db
   %% @private
  --spec(close_db(atom()) ->
  -             ok).
  -close_db(InstanseName) ->
  +-spec(close_db(InstanceName, Count, StateFilePath) ->
  +             ok when InstanceName::atom(),
  +                     Count::non_neg_integer(),
  +                     StateFilePath::string()).
  +close_db(InstanseName, Count, StateFilePath) ->
  +    %% Output the current state
  +    _ = leo_file:file_unconsult(StateFilePath, [{id, InstanseName},
  +                                                {count, Count}
  +                                               ]),
  +    %% Close the backend-db
       case whereis(leo_backend_db_sup) of
           Pid when is_pid(Pid) ->
               List = supervisor:which_children(Pid),
  
positive.code:                 mq_properties = #mq_properties{} :: #mq_properties{},
                  count = 0 :: non_neg_integer(),
                  consumer_status = ?ST_IDLING :: state_of_mq(),
                  consumer_batch_of_msgs = 0   :: non_neg_integer(),
                  consumer_interval = 0        :: non_neg_integer()
                 }).
  
  
  
negative.code:                   {?MQ_CNS_PROP_INTERVAL, Interval}
                   ]}, State, ?DEF_TIMEOUT};
  
  handle_call(close, _From, #state{count = Count,
                                   state_filepath = StateFilePath,
                                   mq_properties = MQProps} = State) ->
      MQDBMessageId = MQProps#mq_properties.mqdb_id,
      ok = close_db(MQDBMessageId, Count, StateFilePath),
      {reply, ok, State, ?DEF_TIMEOUT};
  
  handle_call(stop, _From, State) ->
  