anchor.diff:  %%
   -spec(consume(atom()) -> ok | {error, any()}).
   consume(Id) ->
  -    gen_server:cast(Id, {consume}).
  -
  -%% -spec(consume(atom(), consume_type()) -> ok | {error, any()}).
  -%% consume(Id, Type) ->
  -%%     gen_server:cast(Id, {consume, Type}).
  +    gen_server:cast(Id, consume).
   
   
   %% @doc get state from the queue.
  
positive.code:             {stop, "Not initialized"}
      end.
  
  handle_call({status}, _From, #state{backend_index   = MQDBIndexId,
                                      backend_message = MQDBMessageId} = State) ->
      Res0 = leo_backend_db_api:status(MQDBIndexId),
      Res1 = leo_backend_db_api:status(MQDBMessageId),
  
  
negative.code: -spec(status(atom()) ->
               {ok, list()}).
  status(Id) ->
      gen_server:call(Id, status, ?DEF_TIMEOUT).
  
  
  %%--------------------------------------------------------------------
  