@Test public void testInitialize() throws Exception { instance.initialize(); Mockito.verify(clusterSingletonService).registerClusterSingletonService(instance); }
public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); try { singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); } catch (Exception e) { LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); } }
SxpIseAdapterProviderInstance implements ClusterSingletonService, AutoCloseable { public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); try { singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); } catch (Exception e) { LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); } } }
SxpIseAdapterProviderInstance implements ClusterSingletonService, AutoCloseable { public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); try { singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); } catch (Exception e) { LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); } } SxpIseAdapterProviderInstance(final DataBroker dataBroker,
                                         final BindingAwareBroker bindingAwareBroker,
                                         final ClusterSingletonServiceProvider clusterSingletonService,
                                         final SxpEpProviderProvider sxpEpProvider); }
SxpIseAdapterProviderInstance implements ClusterSingletonService, AutoCloseable { public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); try { singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); } catch (Exception e) { LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); } } SxpIseAdapterProviderInstance(final DataBroker dataBroker,
                                         final BindingAwareBroker bindingAwareBroker,
                                         final ClusterSingletonServiceProvider clusterSingletonService,
                                         final SxpEpProviderProvider sxpEpProvider); void initialize(); @Override void instantiateServiceInstance(); @Override ListenableFuture<Void> closeServiceInstance(); @Override void close(); @Override ServiceGroupIdentifier getIdentifier(); }
SxpIseAdapterProviderInstance implements ClusterSingletonService, AutoCloseable { public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); try { singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); } catch (Exception e) { LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); } } SxpIseAdapterProviderInstance(final DataBroker dataBroker,
                                         final BindingAwareBroker bindingAwareBroker,
                                         final ClusterSingletonServiceProvider clusterSingletonService,
                                         final SxpEpProviderProvider sxpEpProvider); void initialize(); @Override void instantiateServiceInstance(); @Override ListenableFuture<Void> closeServiceInstance(); @Override void close(); @Override ServiceGroupIdentifier getIdentifier();  }