anchor.diff:                               end,
                   timer:sleep(Interval_1),
                   run(Id),
  -                {?ST_RUNNING,  State};
  +                {?ST_RUNNING,  State#state{prev_proc_time = leo_date:clock()}};
               %% Reached end of the object-container
               not_found ->
                   {_,State_1} = after_execute(ok, State),
  
positive.code:                                   mod_callback = Mod},
                 named_mqdb_pid = NamedMqDbPid,
                 batch_of_msgs  = NumOfBatchProcs,
                 interval = Interval,
                 prev_proc_time = PrevProcTime} = _State) ->
      ThisTime = leo_date:clock(),
      Diff = erlang:round((ThisTime - PrevProcTime) / 1000),
  
      case (Diff >= Interval) of
          true ->
              NumOfBatchProcs_1 = leo_math:ceiling(NumOfBatchProcs / NumOfProcs),
              consume(PublisherId, Mod, NamedMqDbPid, NumOfBatchProcs_1);
  
negative.code:                 {_,State_1} = after_execute({error, Cause}, State),
                  {?ST_IDLING,  State_1};
              {error, short_interval} ->
                  %% {_,State_1} = after_execute(ok, State),
                  {?ST_RUNNING,  State};
              %% An epected error has occured
              {error, Cause} ->
                  {_,State_1} = after_execute({error, Cause}, State),
  