anchor.diff:          case catch consume(State, IsForceExec) of
               %% Execute the data-compaction repeatedly
               ok ->
  -                Interval_1 = case Interval of
  -                                 0 ->
  -                                     ?DEF_CONSUME_MIN_INTERVAL;
  -                                 _ ->
  -                                     Interval
  -                             end,
  -                timer:apply_after(Interval_1, ?MODULE, run, [Id]),
  +                case (Interval < 1) of
  +                    true ->
  +                        void;
  +                    false ->
  +                        timer:sleep(Interval)
  +                end,
  +                _ = spawn(?MODULE, run, [Id]),
                   {?ST_RUNNING, State};
               %% Reached end of the object-container
               not_found ->
  
positive.code:     Interval_1 = decr_interval_fun(Interval, StepInterval),
  
      %% To the next status
      timer:apply_after(timer:seconds(1), ?MODULE, run, [Id]),
      NextStatus = ?ST_RUNNING,
      ok = leo_mq_server:update_consumer_stats(
             PublisherId, NextStatus, BatchOfMsgs_1, Interval_1),
  
negative.code:                                                   {publisher_id, PublisherId},
                                                    {interval, Interval},
                                                    {batch_of_msgs, BatchOfMsgs}]}]),
      ok = defer_consume(Id, ?DEF_CHECK_MAX_INTERVAL_1, ?DEF_CHECK_MIN_INTERVAL_1),
      NamedPid = list_to_atom(atom_to_list(MqDbId)
                              ++ "_"
                              ++ integer_to_list(WorkerSeqNum)),
  