code: @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();
      }
docs: ~ Methods **************************************************************************************************************************************