anchor.diff:      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, "running/2 - event_incr"},
  -                           {line, ?LINE}, {body, [{id, Id},
  -                                                  {batch_of_msgs, BatchOfMsgs_1},
  -                                                  {interval, Interval_1}
  -                                                 ]}]),
  +
       %% Modify the items
       NextStatus = ?ST_RUNNING,
       ok = run(Id),
  
positive.code: 
  %% @doc Handling all non call/cast messages
  handle_info(timeout, StateName, #state{id = Id} = State) ->
      error_logger:info_msg("~p,~p,~p,~p~n",
                            [{module, ?MODULE_STRING}, {function, "handle_info/3"},
                             {line, ?LINE}, {body, [{id, Id},
                                                    {cause, timeout}]}]),
      erlang:apply(?MODULE, run, [Id]),
      {next_state, StateName, State, ?DEF_TIMEOUT};
  handle_info(_Info, StateName, State) ->
  
negative.code:     {ok, {StepBatchOfMsgs, StepInterval}} = ?step_comsumption_values(MQProps),
      BatchOfMsgs_1 = incr_batch_procs_fun(BatchOfMsgs, MaxBatchOfMsgs, StepBatchOfMsgs),
      Interval_1 = decr_interval_fun(Interval, StepInterval),
  
      %% To the next status
      timer:apply_after(timer:seconds(1), ?MODULE, run, [Id]),
      NextStatus = ?ST_RUNNING,
  