aclservice/impl/src/main/java/org/opendaylight/netvirt/aclservice/recovery/AclServiceRecoveryHandler.java

   1 /*
   2  * Copyright (c) 2018 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.netvirt.aclservice.recovery;
   9
  10 import java.util.Queue;
  11
  12 import javax.inject.Inject;
  13 import javax.inject.Singleton;
  14
  15 import org.opendaylight.netvirt.aclservice.utils.AclServiceUtils;
  16 import org.opendaylight.serviceutils.srm.RecoverableListener;
  17 import org.opendaylight.serviceutils.srm.ServiceRecoveryInterface;
  18 import org.opendaylight.serviceutils.srm.ServiceRecoveryRegistry;
  19 import org.slf4j.Logger;
  20 import org.slf4j.LoggerFactory;
  21
  22 @Singleton
  23 public class AclServiceRecoveryHandler implements ServiceRecoveryInterface {
  24
  25     private static final Logger LOG = LoggerFactory.getLogger(AclServiceRecoveryHandler.class);
  26     private final ServiceRecoveryRegistry serviceRecoveryRegistry;
  27
  28     @Inject
  29     public AclServiceRecoveryHandler(final ServiceRecoveryRegistry serviceRecoveryRegistry) {
  30         LOG.info("Registering IFM service recovery handlers");
  31         this.serviceRecoveryRegistry = serviceRecoveryRegistry;
  32         serviceRecoveryRegistry.registerServiceRecoveryRegistry(AclServiceUtils.getRecoverServiceRegistryKey(), this);
  33     }
  34
  35     private void deregisterListeners() {
  36         Queue<RecoverableListener> recoverableListeners =
  37                 serviceRecoveryRegistry.getRecoverableListeners(AclServiceUtils.getRecoverServiceRegistryKey());
  38         recoverableListeners.forEach((RecoverableListener::deregisterListener));
  39     }
  40
  41     private void registerListeners() {
  42         Queue<RecoverableListener> recoverableListeners =
  43                 serviceRecoveryRegistry.getRecoverableListeners(AclServiceUtils.getRecoverServiceRegistryKey());
  44         recoverableListeners.forEach((RecoverableListener::registerListener));
  45     }
  46
  47     @Override
  48     public void recoverService(final String entityId) {
  49         LOG.info("Recover IFM service by deregistering and registering all relevant listeners");
  50         deregisterListeners();
  51         registerListeners();
  52     }
  53 }