BulkProcessorUpdater extends ComponentSupport implements Callable<Void> { @Override public Void call() { log.debug("Trying to add index/delete request to batch."); this.bulkProcessor.add(actionRequest); log.debug("Added index/delete request to batch."); return null; } BulkProcessorUpdater(final BulkProcessor bulkProcessor, final T actionRequest); @Override Void call();  }
@Test public void runShouldAddRequestToBulkProcessor() { underTest.call(); verify(bulkProcessor).add(deleteRequest); }