anchor.diff:                  {_,State_1} = after_execute({error, Cause}, State),
                   {?ST_IDLING,  State_1};
               {error, short_interval} ->
  -                {_,State_1} = after_execute(ok, State),
  -                {?ST_RUNNING,  State_1};
  +                %% {_,State_1} = after_execute(ok, State),
  +                {?ST_RUNNING,  State};
               %% An epected error has occured
               {error, Cause} ->
                   {_,State_1} = after_execute({error, Cause}, State),
  
positive.code: %%--------------------------------------------------------------------
  %% @doc after processing of consumption messages
  %% @private
  after_execute(Ret, #state{id = Id,
                            prev_proc_time = PrevProcTime} = State) ->
      ThisTime = leo_date:clock(),
      Diff = erlang:round((ThisTime - PrevProcTime) / 1000),
      case (Diff >= ?DEF_CONSUME_MIN_INTERVAL) of
          true ->
              _ = defer_consume(Id, ?DEF_CHECK_MAX_INTERVAL_2,
                                ?DEF_CHECK_MIN_INTERVAL_2);
          false ->
              void
      end,
      {Ret, State}.
  
  
  %% @doc Consume a message
  
negative.code: 
      ok = leo_mq_publisher:update_consumer_stats(
             PublisherId, NextStatus, BatchOfMsgs, Interval),
      {next_state, NextStatus, State_2#state{status = NextStatus}, ?DEF_TIMEOUT};
  
  running(#event_info{event = ?EVENT_SUSPEND}, #state{publisher_id = PublisherId,
                                                      batch_of_msgs = BatchOfMsgs,
  