@Override public void endRDF() throws RDFHandlerException {
  logger.info("Finished parsing RDF");
  try {
    statementCache.put(DONE);
  }
 catch (  InterruptedException e) {
    throw new RDFHandlerException("Interrupted while waiting to add done signal to statement queue",e);
  }
}

@ Override public void endRDF ( ) throws RDFHandlerException { logger . info ( "Finished parsing RDF" ) ; try { statementCache . put ( DONE ) ; } catch ( InterruptedException e ) { throw new RDFHandlerException ( "Interrupted while waiting to add done signal to statement queue" , e ) ; } }
add a dummy item to the queue to signal that there will be no more statements .
