BUG 3030 - reconnect netconf event source

[controller.git] / opendaylight / md-sal / messagebus-impl / src / main / java / org / opendaylight / controller / messagebus / app / impl / EventSourceTopic.java

diff --git a/opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/EventSourceTopic.java b/opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/EventSourceTopic.java
index c60562d3d4392dca7f5e1e3ca40da4e8bbe9961b..6de407f58be5d999961e82e03d572162ce2900d6 100644 (file)
--- a/opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/EventSourceTopic.java
+++ b/opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/EventSourceTopic.java
@@ -53,7 +53,7 @@ public class EventSourceTopic implements DataChangeListener {
                 for (final Map.Entry<InstanceIdentifier<?>, DataObject> changeEntry : event.getUpdatedData().entrySet()) {
             if (changeEntry.getValue() instanceof Node) {
                 final Node node = (Node) changeEntry.getValue();
-                if (nodeIdPattern.matcher(node.getId().getValue()).matches()) {
+                if (getNodeIdRegexPattern().matcher(node.getId().getValue()).matches()) {
                     notifyNode(changeEntry.getKey());
                 }
             }
@@ -85,4 +85,8 @@ public class EventSourceTopic implements DataChangeListener {
         return jti;
     }
 
+    public Pattern getNodeIdRegexPattern() {
+        return nodeIdPattern;
+    }
+
 }