anchor.diff:  
   %% @doc Defer a cosuming message
   %%
  --spec(defer_consume(atom(), pos_integer(), integer()) ->
  -             {ok, timer:tref()} | {error,_}).
  +-spec(defer_consume(Id, MaxInterval, MinInterval) ->
  +             ok | {error,_} when Id::atom(),
  +                                 MaxInterval::pos_integer(),
  +                                 MinInterval::pos_integer()).
   defer_consume(Id, MaxInterval, MinInterval) ->
  -    defer_consume(Id, MaxInterval, MinInterval, false).
  -
  --spec(defer_consume(atom(), pos_integer(), integer(), boolean()) ->
  -             {ok, timer:tref()} | {error,_}).
  -defer_consume(Id, MaxInterval, MinInterval,_FromHandleInfo) ->
       Time = interval(Id, MinInterval, MaxInterval),
  -    timer:apply_after(Time, ?MODULE, run, [Id]).
  +    _ = timer:apply_after(Time, ?MODULE, run, [Id]),
  +    ok.
   
   
   %% @doc Retrieve interval of the waiting proc
  
positive.code: %% @doc after processing of consumption messages
  %% @private
  after_execute(Ret, #state{id = Id} = State) ->
      _ = defer_consume(Id, ?DEF_CHECK_MAX_INTERVAL_2,
                        ?DEF_CHECK_MIN_INTERVAL_2),
      {Ret, State}.
  
  
  
negative.code:         case catch consume(State, IsForceExec) of
              %% Execute the data-compaction repeatedly
              ok ->
                  case (Interval < 1) of
                      true ->
                          void;
                      false ->
                          timer:sleep(Interval)
                  end,
                  _ = spawn(?MODULE, run, [Id]),
                  {?ST_RUNNING, State};
              %% Reached end of the object-container
              not_found ->
  