neutron-ovsdb/src/main/java/org/opendaylight/groupbasedpolicy/neutron/ovsdb/NeutronOvsdb.java

   1 package org.opendaylight.groupbasedpolicy.neutron.ovsdb;
   2
   3 import static com.google.common.base.Preconditions.checkNotNull;
   4
   5 import java.util.ArrayList;
   6 import java.util.List;
   7
   8 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
   9 import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.EndpointService;
  11 import org.osgi.framework.BundleContext;
  12 import org.osgi.framework.ServiceRegistration;
  13
  14 public class NeutronOvsdb implements AutoCloseable {
  15
  16     private final List<ServiceRegistration<?>> registrations = new ArrayList<ServiceRegistration<?>>();
  17     private final OvsdbDataChangeListener listener;
  18     public NeutronOvsdb(DataBroker dataProvider, RpcProviderRegistry rpcProvider, BundleContext context) {
  19         checkNotNull(dataProvider);
  20         checkNotNull(rpcProvider);
  21         checkNotNull(context);
  22
  23         EndpointService epService = rpcProvider.getRpcService(EndpointService.class);
  24         listener = new OvsdbDataChangeListener(dataProvider, epService);
  25     }
  26
  27     /**
  28      * @see java.lang.AutoCloseable#close()
  29      */
  30     @Override
  31     public void close() throws Exception {
  32         for (ServiceRegistration<?> registration : registrations) {
  33             registration.unregister();
  34         }
  35     }
  36
  37 }