anchor.diff:      %% Modify the item
       BatchOfMsgs_1 = incr_batch_procs_fun(BatchOfMsgs, MaxBatchOfMsgs, StepBatchOfMsgs),
       Interval_1 = decr_interval_fun(Interval, StepInterval),
  -
  +    error_logger:info_msg("~p,~p,~p,~p~n",
  +                          [{module, ?MODULE_STRING}, {function, "suspending/2 - event_incr"},
  +                           {line, ?LINE}, {body, [{id, Id},
  +                                                  {batch_of_msgs, BatchOfMsgs_1},
  +                                                  {interval, Interval_1}
  +                                                 ]}]),
       %% To the next status
       timer:apply_after(timer:seconds(1), ?MODULE, run, [Id]),
       NextStatus = ?ST_RUNNING,
  
positive.code:     BatchOfMsgs_1 =
          incr_batch_procs_fun(BatchOfMsgs, MaxBatchOfMsgs, StepBatchOfMsgs),
      Interval_1 = decr_interval_fun(Interval, StepInterval),
  
      %% Modify the items
      NextStatus = ?ST_RUNNING,
      ok = run(Id),
  
negative.code:                 {?ST_RUNNING,
                   decr_batch_procs_fun(BatchOfMsgs, StepBatchOfMsgs)}
          end,
      error_logger:info_msg("~p,~p,~p,~p~n",
                            [{module, ?MODULE_STRING}, {function, "running/2 - event_decr"},
                             {line, ?LINE}, {body, [{id, Id},
                                                    {batch_of_msgs, BatchOfMsgs_1},
                                                    {interval, Interval_2}
                                                   ]}]),
      ok = leo_mq_publisher:update_consumer_stats(
             PublisherId, NextStatus, BatchOfMsgs_1, Interval_2),
      {next_state, NextStatus, State#state{batch_of_msgs = BatchOfMsgs_1,
  