- disruptor = new Disruptor<>(DOMNotificationRouterEvent.FACTORY,
- queueDepth, executor, ProducerType.MULTI, strategy);
+ @VisibleForTesting
+ DOMNotificationRouter(final int queueDepth, final WaitStrategy strategy) {
+ observer = new ScheduledThreadPoolExecutor(1,
+ new ThreadFactoryBuilder().setDaemon(true).setNameFormat("DOMNotificationRouter-observer-%d").build());
+ executor = Executors.newCachedThreadPool(
+ new ThreadFactoryBuilder().setDaemon(true).setNameFormat("DOMNotificationRouter-listeners-%d").build());
+ disruptor = new Disruptor<>(DOMNotificationRouterEvent.FACTORY, queueDepth,
+ new ThreadFactoryBuilder().setNameFormat("DOMNotificationRouter-disruptor-%d").build(),
+ ProducerType.MULTI, strategy);