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: -spec(running(EventInfo, State) ->
               {next_state, ?ST_RUNNING, State} when EventInfo::#event_info{},
                                                     State::#state{}).
  running(#event_info{event = ?EVENT_RUN},
          #state{id = Id,
                 mq_properties = #mq_properties{
                                    max_interval = MaxInterval},
                 interval = Interval
                } = State) ->
      {NextStatus, State_2} =
          case catch consume(State) of
              %% Execute the data-compaction repeatedly
              ok ->
                  Time = interval(Interval, MaxInterval),
                  ok = timer:sleep(Time),
                  ok = run(Id),
                  {?ST_RUNNING,  State};
              %% Reached end of the object-container
              not_found ->
  
negative.code:                interval = Interval,
                 batch_of_msgs = BatchOfMsgs} = State) ->
      {NextStatus, Interval_1} =
          case ((Interval + StepInterval) >= MaxInterval andalso
                BatchOfMsgs =< MinBatchProcs) of
              true ->
                  {?ST_SUSPENDING, MaxInterval};
  