From 974e933c616ade79d32bfe16d5ecbcb5df81d120 Mon Sep 17 00:00:00 2001 From: Jan Hajnar Date: Thu, 26 Feb 2015 14:49:41 +0100 Subject: [PATCH] Exception when creating new DOMNotificationRouter * method after(eventHandler) was called on EventHandler that was not started. * added missing disruptor.handleEventsWith() call before handler chaining setup documentation for 'after()' method: https://lmax-exchange.github.io/disruptor/docs/index.html class Disruptor, method after() Change-Id: Icb5390114000d3f1bf1ea4096263ded633d9f123 Signed-off-by: Jan Hajnar --- .../controller/md/sal/dom/broker/impl/DOMNotificationRouter.java | 1 + 1 file changed, 1 insertion(+) diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMNotificationRouter.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMNotificationRouter.java index aac425b3d4..b9972fc0a0 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMNotificationRouter.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMNotificationRouter.java @@ -79,6 +79,7 @@ public final class DOMNotificationRouter implements AutoCloseable, DOMNotificati final ExecutorService executor = Executors.newCachedThreadPool(); final Disruptor disruptor = new Disruptor<>(DOMNotificationRouterEvent.FACTORY, queueDepth, executor, ProducerType.MULTI, DEFAULT_STRATEGY); + disruptor.handleEventsWith(DISPATCH_NOTIFICATIONS); disruptor.after(DISPATCH_NOTIFICATIONS).handleEventsWith(NOTIFY_FUTURE); disruptor.start(); -- 2.36.6