+/*
+ * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
package org.opendaylight.controller.sal.streams.listeners;
import io.netty.channel.Channel;
/**
* Creates new {@link ListenerAdapter} listener specified by path and stream
* name.
- *
+ *
* @param path
* Path to data in data store.
* @param streamName
/**
* Creates new event specified by {@link EventType} type.
- *
+ *
* @param type
* EventType
*/
/**
* Gets the {@link Channel} subscriber.
- *
+ *
* @return Channel
*/
public Channel getSubscriber() {
/**
* Sets subscriber for event.
- *
+ *
* @param subscriber
* Channel
*/
/**
* Gets event data.
- *
+ *
* @return String representation of event data.
*/
public String getData() {
/**
* Sets event data.
- *
+ *
* @param String
* data.
*/
/**
* Gets event type.
- *
+ *
* @return The type of the event.
*/
public EventType getType() {
/**
* Prepare data in printable form and transform it to String.
- *
+ *
* @param change
* DataChangeEvent
* @return Data in printable form.
/**
* Formats data specified by RFC3339.
- *
+ *
* @param d
* Date
* @return Data specified by RFC3339.
/**
* Creates {@link Document} document.
- *
+ *
* @return {@link Document} document.
*/
private Document createDocument() {
/**
* Adds values to data changed notification event element.
- *
+ *
* @param doc
* {@link Document}
* @param dataChangedNotificationEventElement
/**
* Adds values from data to element.
- *
+ *
* @param doc
* {@link Document}
* @param data
/**
* Adds values from data to element.
- *
+ *
* @param doc
* {@link Document}
* @param data
/**
* Creates changed event element from data.
- *
+ *
* @param doc
* {@link Document}
* @param path
/**
* Translates {@link CompositeNode} data to XML format.
- *
+ *
* @param path
* Path to data in data store.
* @param data
/**
* Adds path as value to element.
- *
+ *
* @param path
* Path to data in data store.
* @param element
/**
* Writes identifier that consists of prefix and QName.
- *
+ *
* @param element
* {@link Element}
* @param textContent
}
}
- element.setAttribute("xmlns:" + prefix, namespace.toString());
+ element.setAttribute("xmlns:" + prefix, namespace);
textContent.append(prefix);
prefixes.put(namespace, prefix);
/**
* Generates new prefix which consists of four random characters <a-z>.
- *
+ *
* @param prefixes
* Collection of prefixes.
* @return New prefix which consists of four random characters <a-z>.
/**
* Gets path pointed to data in data store.
- *
+ *
* @return Path pointed to data in data store.
*/
public InstanceIdentifier getPath() {
/**
* Sets {@link ListenerRegistration} registration.
- *
+ *
* @param registration
* ListenerRegistration<DataChangeListener>
*/
/**
* Gets the name of the stream.
- *
+ *
* @return The name of the stream.
*/
public String getStreamName() {
/**
* Checks if {@link ListenerRegistration} registration exist.
- *
+ *
* @return True if exist, false otherwise.
*/
public boolean isListening() {
/**
* Creates event of type {@link EventType#REGISTER}, set {@link Channel}
* subscriber to the event and post event into event bus.
- *
+ *
* @param subscriber
* Channel
*/
/**
* Creates event of type {@link EventType#DEREGISTER}, sets {@link Channel}
* subscriber to the event and posts event into event bus.
- *
+ *
* @param subscriber
*/
public void removeSubscriber(Channel subscriber) {
/**
* Checks if exists at least one {@link Channel} subscriber.
- *
+ *
* @return True if exist at least one {@link Channel} subscriber, false
* otherwise.
*/