anchor.diff:  consume(#state{mq_properties = #mq_properties{
                                     publisher_id = PublisherId,
                                     mod_callback = Mod,
  -                                  mqdb_id = BackendMessage,
  -                                  regular_batch_of_msgs = NumOfBatchProcs
  -                                 }} = _State) ->
  +                                  mqdb_id = BackendMessage},
  +               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) ->
  +consume(_Id,_,_,0) ->
       ok;
   consume(Id, Mod, BackendMessage, NumOfBatchProcs) ->
       try
  
positive.code:     ok = run(Id),
      {next_state, NextStatus, State#state{status = NextStatus}};
  
  idling(_, State) ->
      NextStatus = ?ST_IDLING,
      {next_state, NextStatus, State#state{status = NextStatus}}.
  
negative.code:                interval = Interval,
                 batch_of_msgs = BatchOfMsgs} = State) ->
      {NextStatus, Interval_1} =
          case ((Interval + StepInterval) >= MaxInterval andalso
                BatchOfMsgs =< MinBatchProcs) of
              true ->
                  {?ST_SUSPENDING, MaxInterval};
  