anchor.diff:  %%====================================================================
   %% @doc Initiates the server
   %%
  -init([Id, PublisherId, Props]) ->
  +init([Id, PublisherId, #mq_properties{regular_interval = Interval,
  +                                      regular_batch_of_msgs = BatchOfMsgs} = Props]) ->
       _ = defer_consume(Id, ?DEF_CHECK_MAX_INTERVAL_1, ?DEF_CHECK_MIN_INTERVAL_1),
       {ok, ?ST_IDLING, #state{id = Id,
                               publisher_id  = PublisherId,
  -                            mq_properties = Props}}.
  +                            mq_properties = Props,
  +                            interval      = Interval,
  +                            batch_of_msgs = BatchOfMsgs
  +                           }}.
   
   %% @doc Handle events
   handle_event(_Event, StateName, State) ->
  
positive.code: consume(#state{mq_properties = #mq_properties{
                                    publisher_id = PublisherId,
                                    mod_callback = Mod,
                                    mqdb_id = BackendMessage,
                                    regular_batch_of_msgs = NumOfBatchProcs
                                   }} = _State) ->
      consume(PublisherId, Mod, BackendMessage, NumOfBatchProcs).
  
  %% @doc Consume a message
  %% @private
  -spec(consume(atom(), atom(), atom(), non_neg_integer()) ->
               ok | not_found | {error, any()}).
  consume(_,_,_,0) ->
      ok;
  consume(Id, Mod, BackendMessage, NumOfBatchProcs) ->
      try
  
negative.code:                interval = Interval,
                 batch_of_msgs = BatchOfMsgs} = State) ->
      {NextStatus, Interval_1} =
          case ((Interval + StepInterval) >= MaxInterval andalso
                BatchOfMsgs =< MinBatchProcs) of
              true ->
                  {?ST_SUSPENDING, MaxInterval};
  