2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.controller.messagebus.app.impl;
11 import com.google.common.base.Preconditions;
12 import java.util.regex.Pattern;
13 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
14 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
15 import org.opendaylight.controller.mdsal.MdSAL;
16 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventaggregator.rev141202.NotificationPattern;
17 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventaggregator.rev141202.TopicId;
18 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventsource.rev141202.EventSourceService;
19 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventsource.rev141202.JoinTopicInput;
20 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventsource.rev141202.JoinTopicInputBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
24 import org.opendaylight.yangtools.yang.binding.DataObject;
25 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
26 import org.slf4j.LoggerFactory;
28 public class Topic implements DataChangeListener {
29 private static final org.slf4j.Logger LOG = LoggerFactory.getLogger(Topic.class);
30 private final NotificationPattern notificationPattern;
31 private final Pattern nodeIdPattern;
32 private final TopicId topicId;
33 private final MdSAL mdSal;
35 public Topic(final NotificationPattern notificationPattern, final String nodeIdPattern, final MdSAL mdSal) {
36 this.notificationPattern = Preconditions.checkNotNull(notificationPattern);
38 // FIXME: regex should be the language of nodeIdPattern
39 final String regex = Util.wildcardToRegex(nodeIdPattern);
40 this.nodeIdPattern = Pattern.compile(regex);
41 this.mdSal = Preconditions.checkNotNull(mdSal);
43 // FIXME: We need to perform some salting in order to make
44 // the topic IDs less predictable.
45 this.topicId = new TopicId(Util.md5String(notificationPattern + nodeIdPattern));
48 public TopicId getTopicId() {
53 public void onDataChanged(final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> event) {
54 // TODO: affected must return topologyNode !!!
55 final Node node = Util.getAffectedNode(event);
56 if (nodeIdPattern.matcher(node.getId().getValue()).matches()) {
57 notifyNode(node.getId());
59 LOG.debug("Skipping node {}", node.getId());
63 public void notifyNode(final NodeId nodeId) {
64 JoinTopicInput jti = getJoinTopicInputArgument(nodeId);
65 EventSourceService ess = mdSal.getRpcService(EventSourceService.class);
66 Preconditions.checkState(ess != null, "EventSourceService is not registered");
71 private JoinTopicInput getJoinTopicInputArgument(final NodeId nodeId) {
72 NodeRef nodeRef = MdSAL.createNodeRef(nodeId);
74 new JoinTopicInputBuilder()
75 .setNode(nodeRef.getValue())
77 .setNotificationPattern(notificationPattern)