opendaylight/md-sal/test/zeromq-test-provider/src/main/java/org/opendaylight/controller/sample/zeromq/provider/ExampleProvider.java

   1 package org.opendaylight.controller.sample.zeromq.provider;
   2
   3 import java.net.URI;
   4 import java.util.Collection;
   5 import java.util.Collections;
   6 import java.util.Set;
   7
   8 import org.opendaylight.controller.sal.common.util.Rpcs;
   9 import org.opendaylight.controller.sal.core.api.AbstractProvider;
  10 import org.opendaylight.controller.sal.core.api.Broker.ProviderSession;
  11 import org.opendaylight.controller.sal.core.api.Broker.RpcRegistration;
  12 import org.opendaylight.controller.sal.core.api.RpcImplementation;
  13 import org.opendaylight.yangtools.yang.common.QName;
  14 import org.opendaylight.yangtools.yang.common.RpcError;
  15 import org.opendaylight.yangtools.yang.common.RpcResult;
  16 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
  17 import org.osgi.framework.BundleContext;
  18
  19 public class ExampleProvider extends AbstractProvider implements RpcImplementation  {
  20
  21     private final URI namespace = URI.create("http://cisco.com/example");
  22     private final QName QNAME = new QName(namespace,"heartbeat");
  23     private RpcRegistration reg;
  24
  25
  26     @Override
  27     public void onSessionInitiated(ProviderSession session) {
  28       //Adding heartbeat 10 times just to make sure subscriber get it
  29       for (int i=0;i<10;i++){
  30         System.out.println("ExampleProvider: Adding " + QNAME + " " + i);
  31         reg = session.addRpcImplementation(QNAME, this);
  32         try {
  33           Thread.sleep(1000);
  34         } catch (InterruptedException e) {
  35           e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
  36         }
  37       }
  38     }
  39
  40     @Override
  41     public Set<QName> getSupportedRpcs() {
  42         return Collections.singleton(QNAME);
  43     }
  44
  45     @Override
  46     public RpcResult<CompositeNode> invokeRpc(QName rpc, CompositeNode input) {
  47         if(QNAME.equals(rpc)) {
  48             RpcResult<CompositeNode> output = Rpcs.getRpcResult(true, null, Collections.<RpcError>emptySet());
  49             return output;
  50         }
  51         RpcResult<CompositeNode> output = Rpcs.getRpcResult(false, null, Collections.<RpcError>emptySet());
  52         return output;
  53     }
  54
  55     @Override
  56     protected void stopImpl(BundleContext context) {
  57      if(reg != null) {
  58          try {
  59             reg.close();
  60         } catch (Exception e) {
  61             // TODO Auto-generated catch block
  62             e.printStackTrace();
  63         }
  64      }
  65     }
  66
  67 }