opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/config/yang/config/actor_system_provider/impl/ActorSystemProviderModule.java

   1 /*
   2  * Copyright (c) 2015 Brocade Communications Systems, Inc. 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
   9 package org.opendaylight.controller.config.yang.config.actor_system_provider.impl;
  10
  11 import akka.actor.ActorSystem;
  12 import com.google.common.collect.ForwardingObject;
  13 import org.opendaylight.controller.cluster.ActorSystemProvider;
  14 import org.opendaylight.controller.cluster.ActorSystemProviderListener;
  15 import org.opendaylight.controller.config.api.DependencyResolver;
  16 import org.opendaylight.controller.config.api.ModuleIdentifier;
  17 import org.opendaylight.controller.config.api.osgi.WaitingServiceTracker;
  18 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  19 import org.osgi.framework.BundleContext;
  20
  21 public class ActorSystemProviderModule extends AbstractActorSystemProviderModule {
  22     private BundleContext bundleContext;
  23
  24     public ActorSystemProviderModule(ModuleIdentifier identifier, DependencyResolver dependencyResolver) {
  25         super(identifier, dependencyResolver);
  26     }
  27
  28     public ActorSystemProviderModule(ModuleIdentifier identifier, DependencyResolver dependencyResolver,
  29             ActorSystemProviderModule oldModule, AutoCloseable oldInstance) {
  30         super(identifier, dependencyResolver, oldModule, oldInstance);
  31     }
  32
  33     @Override
  34     public void customValidation() {
  35         // add custom validation form module attributes here.
  36     }
  37
  38     @Override
  39     public boolean canReuseInstance(AbstractActorSystemProviderModule oldModule) {
  40         return true;
  41     }
  42
  43     @Override
  44     public AutoCloseable createInstance() {
  45         // The service is provided via blueprint so wait for and return it here for backwards compatibility.
  46         WaitingServiceTracker<ActorSystemProvider> tracker = WaitingServiceTracker.create(
  47                 ActorSystemProvider.class, bundleContext);
  48         ActorSystemProvider delegate = tracker.waitForService(WaitingServiceTracker.FIVE_MINUTES);
  49         return new ForwardingActorSystemProvider(delegate, tracker);
  50     }
  51
  52     public void setBundleContext(BundleContext bundleContext) {
  53         this.bundleContext = bundleContext;
  54     }
  55
  56     private static class ForwardingActorSystemProvider extends ForwardingObject
  57             implements ActorSystemProvider, AutoCloseable {
  58         private final ActorSystemProvider delegate;
  59         private final AutoCloseable closeable;
  60
  61         ForwardingActorSystemProvider(ActorSystemProvider delegate, AutoCloseable closeable) {
  62             this.delegate = delegate;
  63             this.closeable = closeable;
  64         }
  65
  66         @Override
  67         public ActorSystem getActorSystem() {
  68             return delegate().getActorSystem();
  69         }
  70
  71         @Override
  72         public ListenerRegistration<ActorSystemProviderListener> registerActorSystemProviderListener(
  73                 ActorSystemProviderListener listener) {
  74             return delegate().registerActorSystemProviderListener(listener);
  75         }
  76
  77         @Override
  78         protected ActorSystemProvider delegate() {
  79             return delegate;
  80         }
  81
  82         @Override
  83         public void close() throws Exception {
  84             // We don't close the delegate as the life-cycle is controlled via blueprint.
  85             closeable.close();
  86         }
  87     }
  88 }