anchor.diff:      {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{},
  -                                                                    From::{pid(),Tag::atom()},
  -                                                                    State::#state{}).
  +             {next_state, ?ST_SUSPENDING | ?ST_RUNNING, State, non_neg_integer()}
  +                 when EventInfo::#event_info{},
  +                      From::{pid(),Tag::atom()},
  +                      State::#state{}).
   suspending(#event_info{event = ?EVENT_RESUME}, From, #state{id = Id,
                                                               publisher_id = PublisherId,
                                                               batch_of_msgs = BatchOfMsgs,
  
positive.code: 
  %% @doc Increase comsumption processing
  -spec(increase(Id) ->
               {ok, state_of_mq()} when Id::atom()).
  increase(Id) ->
      gen_fsm:send_event(Id, #event_info{event = ?EVENT_INCR}).
  
  
  %% @doc Decrease comsumption processing
  -spec(decrease(Id) ->
               {ok, state_of_mq()} when Id::atom()).
  decrease(Id) ->
      gen_fsm:send_event(Id, #event_info{event = ?EVENT_DECR}).
  
  
negative.code:     {next_state, ?ST_RUNNING, State#state{status = ?ST_RUNNING}, ?DEF_TIMEOUT}.
  
  -spec(running( _, _, #state{}) ->
               {next_state, ?ST_RUNNING, #state{}, non_neg_integer()}).
  running(#event_info{event = ?EVENT_STATE}, From, #state{status = Status} = State) ->
      gen_fsm:reply(From, {ok, Status}),
      {next_state, ?ST_RUNNING, State#state{status = ?ST_RUNNING}, ?DEF_TIMEOUT};
  