mdsalutil/mdsalutil-impl/src/main/java/org/opendaylight/vpnservice/mdsalutil/internal/MDSALUtilProvider.java

   1 package org.opendaylight.vpnservice.mdsalutil.internal;
   2
   3 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
   4 import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer;
   5 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext;
   6 import org.opendaylight.vpnservice.mdsalutil.interfaces.IMdsalApiManager;
   7 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingService;
   8 import org.slf4j.Logger;
   9 import org.slf4j.LoggerFactory;
  10
  11 public class MDSALUtilProvider implements BindingAwareConsumer, AutoCloseable {
  12
  13     private static final Logger s_logger = LoggerFactory.getLogger(MDSALUtilProvider.class);
  14     private MDSALManager mdSalMgr;
  15
  16     @Override
  17     public void onSessionInitialized(ConsumerContext session) {
  18
  19         s_logger.info( " Session Initiated for MD SAL Util Provider") ;
  20
  21         try {
  22             final DataBroker dataBroker;
  23             final PacketProcessingService packetProcessingService;
  24             dataBroker = session.getSALService(DataBroker.class);
  25              // TODO - Verify this.
  26              packetProcessingService = session.getRpcService(PacketProcessingService.class);
  27              mdSalMgr = new MDSALManager( dataBroker, packetProcessingService) ;
  28         }catch( Exception e) {
  29             s_logger.error( "Error initializing MD SAL Util Services " + e );
  30         }
  31     }
  32
  33
  34     @Override
  35     public void close() throws Exception {
  36         mdSalMgr.close();
  37         s_logger.info("MDSAL Manager Closed");
  38     }
  39
  40 }