X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Ftest%2Fzeromq-test-provider%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsample%2Fzeromq%2Fprovider%2FExampleProvider.java;fp=opendaylight%2Fmd-sal%2Ftest%2Fzeromq-test-provider%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsample%2Fzeromq%2Fprovider%2FExampleProvider.java;h=0000000000000000000000000000000000000000;hb=97a4294baa44125d53a7ee2a3646f8a1c8da73e6;hp=ec7d7a828534f09f1dd87eef460d6c071db9dc7b;hpb=3207207ec5ddd9032bad9d019c9bb88c33cad4f3;p=controller.git

diff --git a/opendaylight/md-sal/test/zeromq-test-provider/src/main/java/org/opendaylight/controller/sample/zeromq/provider/ExampleProvider.java b/opendaylight/md-sal/test/zeromq-test-provider/src/main/java/org/opendaylight/controller/sample/zeromq/provider/ExampleProvider.java
deleted file mode 100644
index ec7d7a8285..0000000000
--- a/opendaylight/md-sal/test/zeromq-test-provider/src/main/java/org/opendaylight/controller/sample/zeromq/provider/ExampleProvider.java
+++ /dev/null
@@ -1,67 +0,0 @@
-package org.opendaylight.controller.sample.zeromq.provider;
-
-import java.net.URI;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.Set;
-
-import org.opendaylight.controller.sal.common.util.Rpcs;
-import org.opendaylight.controller.sal.core.api.AbstractProvider;
-import org.opendaylight.controller.sal.core.api.Broker.ProviderSession;
-import org.opendaylight.controller.sal.core.api.Broker.RpcRegistration;
-import org.opendaylight.controller.sal.core.api.RpcImplementation;
-import org.opendaylight.yangtools.yang.common.QName;
-import org.opendaylight.yangtools.yang.common.RpcError;
-import org.opendaylight.yangtools.yang.common.RpcResult;
-import org.opendaylight.yangtools.yang.data.api.CompositeNode;
-import org.osgi.framework.BundleContext;
-
-public class ExampleProvider extends AbstractProvider implements RpcImplementation  {
-
-    private final URI namespace = URI.create("http://cisco.com/example");
-    private final QName QNAME = new QName(namespace,"heartbeat");
-    private RpcRegistration reg;
-    
-    
-    @Override
-    public void onSessionInitiated(ProviderSession session) {
-      //Adding heartbeat 10 times just to make sure subscriber get it
-      for (int i=0;i<10;i++){
-        System.out.println("ExampleProvider: Adding " + QNAME + " " + i);
-        reg = session.addRpcImplementation(QNAME, this);
-        try {
-          Thread.sleep(1000);
-        } catch (InterruptedException e) {
-          e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
-        }
-      }
-    }
-    
-    @Override
-    public Set<QName> getSupportedRpcs() {
-        return Collections.singleton(QNAME);
-    }
-    
-    @Override
-    public RpcResult<CompositeNode> invokeRpc(QName rpc, CompositeNode input) {
-        if(QNAME.equals(rpc)) {
-            RpcResult<CompositeNode> output = Rpcs.getRpcResult(true, null, Collections.<RpcError>emptySet());
-            return output;
-        }
-        RpcResult<CompositeNode> output = Rpcs.getRpcResult(false, null, Collections.<RpcError>emptySet());
-        return output;
-    }
-    
-    @Override
-    protected void stopImpl(BundleContext context) {
-     if(reg != null) {
-         try {
-            reg.close();
-        } catch (Exception e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        }
-     }
-    }
-
-}