hosttracker/implementation/src/main/java/org/opendaylight/l2switch/hosttracker/plugin/internal/HostTrackerConsumer.java

   1 package org.opendaylight.l2switch.hosttracker.plugin.internal;
   2
   3 import org.opendaylight.controller.sal.binding.api.AbstractBindingAwareConsumer;
   4 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext;
   5 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
   6 import org.slf4j.Logger;
   7 import org.slf4j.LoggerFactory;
   8
   9 /**
  10  *
  11  * @author aanm
  12  * @version 0.0.1
  13  */
  14 public class HostTrackerConsumer extends AbstractBindingAwareConsumer
  15         implements AutoCloseable {
  16
  17     private static final Logger log = LoggerFactory.getLogger(HostTrackerConsumer.class);
  18
  19     HostTrackerImpl mdHostTrackerImpl;
  20
  21     public HostTrackerConsumer() {
  22     }
  23
  24     @Override
  25     public void onSessionInitialized(ConsumerContext session) {
  26         log.trace("onSessionInitialized");
  27         DataBroker dataService = session.<DataBroker>getSALService(DataBroker.class);
  28         mdHostTrackerImpl = new HostTrackerImpl(dataService);
  29         mdHostTrackerImpl.registerAsDataChangeListener();
  30     }
  31
  32     @Override
  33     public void close() throws Exception {
  34         if (mdHostTrackerImpl != null) {
  35             mdHostTrackerImpl.close();
  36         }
  37     }
  38
  39 }