anchor.diff:      error_logger:info_msg("~p,~p,~p,~p~n",
                             [{module, ?MODULE_STRING}, {function, "stop/1"},
                              {line, ?LINE}, {body, Id}]),
  -    gen_server:call(Id, stop).
  +    gen_server:call(Id, stop, ?DEF_TIMEOUT).
   
   
   %% @doc register queuing data.
  
positive.code: -spec(status(atom()) ->
               {ok, list()}).
  status(Id) ->
      gen_server:call(Id, {status}).
  
  
  %%--------------------------------------------------------------------
  
negative.code: -define(CONSUME_FORCE,   'force').
  -define(CONSUME_REGULAR, 'regular').
  -type(consume_type() :: ?CONSUME_FORCE | ?CONSUME_REGULAR).
  
  -define(DEF_TIMEOUT, 30000).
  
  -record(state, {id                 :: atom(),
                  module             :: atom(),
  