anchor.diff:      end.
   
   %% @private
  --spec(dequeue_1(DelBucketStateList, MQId) ->
  +-spec(dequeue_1(State, DelBucketStateList, MQId) ->
                ok |
                not_found |
  -             {error, Cause} when DelBucketStateList::[],
  +             {error, Cause} when State::#state{},
  +                                 DelBucketStateList::[],
                                    MQId::mq_id(),
                                    Cause::any()).
  -dequeue_1([],_) ->
  +dequeue_1(_,[],_) ->
       not_found;
  -dequeue_1([{_, DelBucketStateBin}|DelBucketStateList], MQId) ->
  +dequeue_1(State, [{_, DelBucketStateBin}|DelBucketStateList], MQId) ->
       case catch binary_to_term(DelBucketStateBin) of
           #del_dir_state{type = Type,
                          directory = Directory,
  
positive.code:                          end, [], DelBucketStateList))),
              case List of
                  [H|_] ->
                      Ret = dequeue_1(DelBucketStateList, H),
                      {Ret, State};
                  [] ->
                      {ok, State}
  
negative.code:                     timestamp = leo_date:now()}),
      {noreply, State};
  
  %handle_info({enqueuing, MQId, Type, Directory}, State) ->
  %    {ok, State_1} = run(Type, ?STATE_ENQUEUING, MQId, Directory, State),
  %    {noreply, State_1};
  
  handle_info({enqueued, MQId, Type, Directory}, State) ->
      {ok, State_1} = run(Type, ?STATE_MONITORING, MQId, Directory, State),
  