anchor.diff:  
       ok = leo_mq_publisher:update_consumer_stats(
              PublisherId, NextStatus, BatchOfMsgs, Interval),
  -    {next_state, NextStatus, State_2#state{status = NextStatus,
  -                                           prev_proc_time = leo_date:clock()}, ?DEF_TIMEOUT};
  +    {next_state, NextStatus, State_2#state{status = NextStatus}, ?DEF_TIMEOUT};
   
   running(#event_info{event = ?EVENT_SUSPEND}, #state{publisher_id = PublisherId,
                                                       batch_of_msgs = BatchOfMsgs,
  
positive.code:                              end,
                  timer:sleep(Interval_1),
                  run(Id),
                  {?ST_RUNNING,  State};
              %% Reached end of the object-container
              not_found ->
                  {_,State_1} = after_execute(ok, State),
  
negative.code: %%--------------------------------------------------------------------
  %% @doc after processing of consumption messages
  %% @private
  after_execute(Ret, #state{id = Id} = State) ->
      _ = defer_consume(Id, ?DEF_CHECK_MAX_INTERVAL_2,
                        ?DEF_CHECK_MIN_INTERVAL_2),
      {Ret, State#state{prev_proc_time = 0}}.
  
  
  %% @doc Consume a message
  