anchor.diff:      %% Modify the interval
       #mq_properties{max_interval = MaxInterval} = MQProps,
       {ok, {StepBatchOfMsgs, StepInterval}} = ?step_comsumption_values(MQProps),
  -    Interval_1 = Interval + StepInterval,
  -    Interval_2 = case (Interval_1 >= MaxInterval) of
  -                     true ->
  -                         MaxInterval;
  -                     false ->
  -                         Interval_1
  -                 end,
  +    Interval_1 = incr_interval_fun(Interval, MaxInterval, StepInterval),
   
       %% Modify the items
       {NextStatus, BatchOfMsgs_1} =
  
positive.code:     Interval_1 = Interval - StepInterval,
      case (Interval_1 =< 0) of
          true ->
              10;
          false ->
              Interval_1
      end.
  
negative.code:                           [{module, ?MODULE_STRING}, {function, "running/2 - event_decr"},
                             {line, ?LINE}, {body, [{id, Id},
                                                    {batch_of_msgs, BatchOfMsgs_1},
                                                    {interval, Interval_1}
                                                   ]}]),
      ok = leo_mq_publisher:update_consumer_stats(
             PublisherId, NextStatus, BatchOfMsgs_1, Interval_1),
      {next_state, NextStatus, State#state{batch_of_msgs = BatchOfMsgs_1,
                                           interval = Interval_1,
                                           status = NextStatus}, ?DEF_TIMEOUT};
  
  running(_, State) ->
  