StringConsumerExceptionHandler implements ExceptionHandler<StringEvent> { @Override public void handleOnShutdownException(Throwable ex) { SynchronizingSelfLog.error("Disruptor or AsyncConsumer occurs exception on shutdown", ex); }  @Override void handleEventException(Throwable ex, long sequence, StringEvent event); @Override void handleOnStartException(Throwable ex); @Override void handleOnShutdownException(Throwable ex);  }
@Test public void handleOnShutdownException() throws IOException, InterruptedException { stringConsumerExceptionHandler.handleOnShutdownException(new Throwable()); Assert.assertTrue(checkFileContainError()); }