anchor.diff:  %% @doc State of 'idle'
   %%
   -spec(idling(EventInfo, From, State) ->
  -             {next_state, ?ST_IDLING | ?ST_RUNNING, State} when EventInfo::#event_info{},
  -                                                                From::{pid(),Tag::atom()},
  -                                                                State::#state{}).
  +             {next_state, ?ST_IDLING | ?ST_RUNNING, State, non_neg_integer()}
  +                 when EventInfo::#event_info{},
  +                      From::{pid(), atom()},
  +                      State::#state{}).
   idling(#event_info{event = ?EVENT_RUN}, 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: %% @doc State of 'suspend'
  %%
  -spec(suspending(EventInfo, State) ->
               {next_state, ?ST_SUSPENDING, State, non_neg_integer()}
                   when EventInfo::#event_info{},
                        State::#state{}).
  suspending(#event_info{event = ?EVENT_RUN}, State) ->
      {next_state, ?ST_SUSPENDING, State#state{status = ?ST_SUSPENDING}, ?DEF_TIMEOUT};
  
  