@Test public void doStop() { }
@Override protected void doStop() throws InterruptedException, ExecutionException, TimeoutException { if (future != null) { future.cancel(true); } }
Plc4XConsumer extends DefaultConsumer { @Override protected void doStop() throws InterruptedException, ExecutionException, TimeoutException { if (future != null) { future.cancel(true); } } }
Plc4XConsumer extends DefaultConsumer { @Override protected void doStop() throws InterruptedException, ExecutionException, TimeoutException { if (future != null) { future.cancel(true); } } Plc4XConsumer(Plc4XEndpoint endpoint, Processor processor); }
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); }
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);  }