anchor.diff:                                           batch_of_msgs = BatchOfMsgs_1,
                                            interval = Interval_1}, ?DEF_TIMEOUT};
   suspending(_, State) ->
  -    NextStatus = ?ST_SUSPENDING,
  -    {next_state, NextStatus, State#state{status = NextStatus}, ?DEF_TIMEOUT}.
  +    {next_state, ?ST_SUSPENDING, State#state{status = ?ST_SUSPENDING}, ?DEF_TIMEOUT}.
   
   -spec(suspending(EventInfo, From, State) ->
                {next_state, ?ST_SUSPENDING | ?ST_RUNNING, State} when EventInfo::#event_info{},
  
positive.code:     {ok, {StepBatchOfMsgs, StepInterval}} = ?step_comsumption_values(MQProps),
      BatchOfMsgs_1 = decr_batch_procs_fun(BatchOfMsgs, StepBatchOfMsgs),
      Interval_1 = incr_interval_fun(Interval, MaxInterval, StepInterval),
      NextStatus = ?ST_IDLING,
      {next_state, NextStatus, State#state{status = NextStatus,
                                           batch_of_msgs = BatchOfMsgs_1,
                                           interval = Interval_1}, ?DEF_TIMEOUT};
  idling(_, State) ->
      NextStatus = ?ST_IDLING,
      {next_state, NextStatus, State#state{status = NextStatus}, ?DEF_TIMEOUT}.
  
  
  %% @doc State of 'running'
  
negative.code:              {next_state, ?ST_SUSPENDING, State} when EventInfo::#event_info{},
                                                        State::#state{}).
  suspending(#event_info{event = ?EVENT_RUN}, State) ->
      {next_state, ?ST_SUSPENDING, State#state{status = ?ST_SUSPENDING}, ?DEF_TIMEOUT};
  
  suspending(#event_info{event = ?EVENT_STATE}, State) ->
      {next_state, ?ST_SUSPENDING, State#state{status = ?ST_SUSPENDING}, ?DEF_TIMEOUT};
  
  suspending(#event_info{event = ?EVENT_INCR},
             #state{id = Id,
  