* 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.restconf.nb.rfc8040.streams;
+package org.opendaylight.restconf.server.mdsal.streams.notif;
import static java.util.Objects.requireNonNull;
import org.opendaylight.mdsal.dom.api.DOMNotification;
import org.opendaylight.mdsal.dom.api.DOMNotificationService;
import org.opendaylight.restconf.nb.rfc8040.databind.DatabindProvider;
-import org.opendaylight.restconf.nb.rfc8040.streams.RestconfStream.Sink;
-import org.opendaylight.restconf.nb.rfc8040.streams.RestconfStream.Source;
+import org.opendaylight.restconf.server.spi.RestconfStream.Sink;
+import org.opendaylight.restconf.server.spi.RestconfStream.Source;
import org.opendaylight.yangtools.concepts.Registration;
import org.opendaylight.yangtools.yang.common.QName;
import org.opendaylight.yangtools.yang.model.api.stmt.SchemaNodeIdentifier.Absolute;
/**
* A {@link Source} reporting YANG notifications.
*/
-public final class NotificationSource extends AbstractNotificationSource {
+final class NotificationSource extends AbstractNotificationSource {
private final DatabindProvider databindProvider;
private final DOMNotificationService notificationService;
private final ImmutableSet<QName> qnames;
this.qnames = requireNonNull(qnames);
}
- /**
- * Return notification QNames.
- *
- * @return The YANG notification {@link QName}s this listener is bound to
- */
- public ImmutableSet<QName> qnames() {
- return qnames;
- }
-
@Override
protected Registration start(final Sink<DOMNotification> sink) {
return notificationService.registerNotificationListener(