@Test public void doStop() throws Exception { SUT.doStop(); }
@Override protected void doStop() throws Exception { int openRequestsAtStop = openRequests.get(); log.debug("Stopping with {} open requests", openRequestsAtStop); if (openRequestsAtStop > 0) { log.warn("There are still {} open requests", openRequestsAtStop); } }
Plc4XProducer extends DefaultAsyncProducer { @Override protected void doStop() throws Exception { int openRequestsAtStop = openRequests.get(); log.debug("Stopping with {} open requests", openRequestsAtStop); if (openRequestsAtStop > 0) { log.warn("There are still {} open requests", openRequestsAtStop); } } }
Plc4XProducer extends DefaultAsyncProducer { @Override protected void doStop() throws Exception { int openRequestsAtStop = openRequests.get(); log.debug("Stopping with {} open requests", openRequestsAtStop); if (openRequestsAtStop > 0) { log.warn("There are still {} open requests", openRequestsAtStop); } } Plc4XProducer(Plc4XEndpoint endpoint); }
Plc4XProducer extends DefaultAsyncProducer { @Override protected void doStop() throws Exception { int openRequestsAtStop = openRequests.get(); log.debug("Stopping with {} open requests", openRequestsAtStop); if (openRequestsAtStop > 0) { log.warn("There are still {} open requests", openRequestsAtStop); } } Plc4XProducer(Plc4XEndpoint endpoint); @Override void process(Exchange exchange); @Override boolean process(Exchange exchange, AsyncCallback callback); }
Plc4XProducer extends DefaultAsyncProducer { @Override protected void doStop() throws Exception { int openRequestsAtStop = openRequests.get(); log.debug("Stopping with {} open requests", openRequestsAtStop); if (openRequestsAtStop > 0) { log.warn("There are still {} open requests", openRequestsAtStop); } } Plc4XProducer(Plc4XEndpoint endpoint); @Override void process(Exchange exchange); @Override boolean process(Exchange exchange, AsyncCallback callback);  }