public class MyResourceAdaptor implements ResourceAdaptor {
private ExecutorService executorService;
public void setExecutorService(ExecutorService executorService) {
this.executorService = executorService;
}
// ...
public void deliveryRequest() {
}
public void raActive() {
executorService = Executors.newFixedThreadPool(10);
}
public void raStopping() {
executorService.shutdown();
}
}
