X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsamples%2Fclustering-test-app%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fit%2Fprovider%2Fimpl%2FSingletonGetConstantService.java;h=9177cc6ec7a2370de82887ca5fd7dc5fd9002573;hb=HEAD;hp=6cda13b8ff0df231ad44c6c55ab35a8712b448f1;hpb=a67a54808dc67a28605a92792b3302595569d9c3;p=controller.git diff --git a/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/impl/SingletonGetConstantService.java b/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/impl/SingletonGetConstantService.java index 6cda13b8ff..9177cc6ec7 100644 --- a/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/impl/SingletonGetConstantService.java +++ b/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/impl/SingletonGetConstantService.java @@ -11,52 +11,47 @@ import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import org.opendaylight.mdsal.dom.api.DOMRpcIdentifier; import org.opendaylight.mdsal.dom.api.DOMRpcImplementation; -import org.opendaylight.mdsal.dom.api.DOMRpcImplementationRegistration; import org.opendaylight.mdsal.dom.api.DOMRpcProviderService; import org.opendaylight.mdsal.dom.api.DOMRpcResult; import org.opendaylight.mdsal.dom.spi.DefaultDOMRpcResult; -import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService; -import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider; -import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration; -import org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier; +import org.opendaylight.mdsal.singleton.api.ClusterSingletonService; +import org.opendaylight.mdsal.singleton.api.ClusterSingletonServiceProvider; +import org.opendaylight.mdsal.singleton.api.ServiceGroupIdentifier; +import org.opendaylight.yangtools.concepts.Registration; import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.common.QNameModule; -import org.opendaylight.yangtools.yang.common.Revision; -import org.opendaylight.yangtools.yang.common.XMLNamespace; import org.opendaylight.yangtools.yang.common.YangConstants; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode; -import org.opendaylight.yangtools.yang.data.impl.schema.Builders; -import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes; +import org.opendaylight.yangtools.yang.data.spi.node.ImmutableNodes; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public final class SingletonGetConstantService implements DOMRpcImplementation, ClusterSingletonService { private static final Logger LOG = LoggerFactory.getLogger(SingletonGetConstantService.class); - private static final QNameModule MODULE = QNameModule.create( - XMLNamespace.of("tag:opendaylight.org,2017:controller:yang:lowlevel:target"), Revision.of("2017-02-15")) - .intern(); + private static final QNameModule MODULE = + QNameModule.ofRevision("tag:opendaylight.org,2017:controller:yang:lowlevel:target", "2017-02-15").intern(); private static final QName OUTPUT = YangConstants.operationOutputQName(MODULE).intern(); private static final QName CONSTANT = QName.create(MODULE, "constant").intern(); private static final QName CONTEXT = QName.create(MODULE, "context").intern(); private static final QName GET_SINGLETON_CONSTANT = QName.create(MODULE, "get-singleton-constant").intern(); private static final ServiceGroupIdentifier SERVICE_GROUP_IDENTIFIER = - ServiceGroupIdentifier.create("get-singleton-constant-service"); + new ServiceGroupIdentifier("get-singleton-constant-service"); private final DOMRpcProviderService rpcProviderService; private final String constant; - private DOMRpcImplementationRegistration rpcRegistration; + + private Registration rpcRegistration = null; private SingletonGetConstantService(final DOMRpcProviderService rpcProviderService, final String constant) { this.rpcProviderService = rpcProviderService; this.constant = constant; } - public static ClusterSingletonServiceRegistration registerNew( - final ClusterSingletonServiceProvider singletonService, final DOMRpcProviderService rpcProviderService, - final String constant) { + public static Registration registerNew(final ClusterSingletonServiceProvider singletonService, + final DOMRpcProviderService rpcProviderService, final String constant) { LOG.debug("Registering get-singleton-constant into ClusterSingletonService, value {}", constant); return singletonService.registerClusterSingletonService( @@ -67,7 +62,7 @@ public final class SingletonGetConstantService implements DOMRpcImplementation, public ListenableFuture invokeRpc(final DOMRpcIdentifier rpc, final ContainerNode input) { LOG.debug("get-singleton-constant invoked, current value: {}", constant); - return Futures.immediateFuture(new DefaultDOMRpcResult(Builders.containerBuilder() + return Futures.immediateFuture(new DefaultDOMRpcResult(ImmutableNodes.newContainerBuilder() .withNodeIdentifier(new NodeIdentifier(OUTPUT)) .withChild(ImmutableNodes.leafNode(CONSTANT, constant)) .build()));