@Override
    public void run() {
        while (!Thread.currentThread().isInterrupted()) {
            try {
                int count = collectionService.commitAnnotations(ANNOTATION_CHUNK_SIZE, TIMEOUT);

                if (count > 0) {
                    LOGGER.info(MessageFormat.format("Committed {0} annotations.", count));
                    jobCounter.addAndGet(count);
                }
                Thread.sleep(POLL_INTERVAL_MS);
            } catch (InterruptedException ie) {
                LOGGER.info("Execution was interrupted.");
                Thread.currentThread().interrupt();
                break;
            } catch (Throwable ex) {
                LOGGER.info("Error occurred while committing annotations. Reason {}", ex.toString());
            }
        }
        LOGGER.warn(MessageFormat.format("Annotation committer thread interrupted. {} annotations committed by this thread.", jobCounter.get()));
        collectionService.dispose();
        monitorService.dispose();
    }
@ Override public void run ( ) { while ( ! Thread . currentThread ( ) . isInterrupted ( ) ) { try { int count = collectionService . commitAnnotations ( ANNOTATION_CHUNK_SIZE , TIMEOUT ) ; if ( count > 0 ) { LOGGER . info ( MessageFormat . format ( "Committed {0} annotations." , count ) ) ; jobCounter . addAndGet ( count ) ; } Thread . sleep ( POLL_INTERVAL_MS ) ; } catch ( InterruptedException ie ) { LOGGER . info ( "Execution was interrupted." ) ; Thread . currentThread ( ) . interrupt ( ) ; break ; } catch ( Throwable ex ) { LOGGER . info ( "Error occurred while committing annotations. Reason {}" , ex . toString ( ) ) ; } } LOGGER . warn ( MessageFormat . format ( "Annotation committer thread interrupted. {} annotations committed by this thread." , jobCounter . get ( ) ) ) ; collectionService . dispose ( ) ; monitorService . dispose ( ) ; }
~ Methods **************************************************************************************************************************************