Plc4XConsumer extends DefaultConsumer { @Override protected void doStop() throws InterruptedException, ExecutionException, TimeoutException { if (future != null) { future.cancel(true); } } Plc4XConsumer(Plc4XEndpoint endpoint, Processor processor); @Override String toString(); @Override Endpoint getEndpoint(); ExceptionHandler getExceptionHandler(); void setExceptionHandler(ExceptionHandler exceptionHandler);  }
@Test public void doStop() { }