@Test public void close() throws Exception { controllerInstance.instantiateServiceInstance(); controllerInstance.close(); verify(listenerRegistration, atLeastOnce()).close(); verify(node, atLeastOnce()).close(); verify(serviceRegistration).close(); verify(sxpRpcServiceRegistration).close(); verify(sxpConfigRpcServiceRegistration).close(); }
@Override public synchronized void close() throws Exception { closeServiceInstance().get(); if (clusterServiceRegistration != null) { clusterServiceRegistration.close(); clusterServiceRegistration = null; } }
SxpControllerInstance implements ClusterSingletonService, AutoCloseable { @Override public synchronized void close() throws Exception { closeServiceInstance().get(); if (clusterServiceRegistration != null) { clusterServiceRegistration.close(); clusterServiceRegistration = null; } } }
SxpControllerInstance implements ClusterSingletonService, AutoCloseable { @Override public synchronized void close() throws Exception { closeServiceInstance().get(); if (clusterServiceRegistration != null) { clusterServiceRegistration.close(); clusterServiceRegistration = null; } }  }
SxpControllerInstance implements ClusterSingletonService, AutoCloseable { @Override public synchronized void close() throws Exception { closeServiceInstance().get(); if (clusterServiceRegistration != null) { clusterServiceRegistration.close(); clusterServiceRegistration = null; } }  void init(); @Override synchronized void instantiateServiceInstance(); @Override synchronized ListenableFuture<Void> closeServiceInstance(); @Override ServiceGroupIdentifier getIdentifier(); @Override synchronized void close(); void setDataBroker(DataBroker dataBroker); void setClusteringServiceProvider(ClusterSingletonServiceProvider clusteringServiceProvider); void setRpcProviderService(RpcProviderService rpcProviderService); }
SxpControllerInstance implements ClusterSingletonService, AutoCloseable { @Override public synchronized void close() throws Exception { closeServiceInstance().get(); if (clusterServiceRegistration != null) { clusterServiceRegistration.close(); clusterServiceRegistration = null; } }  void init(); @Override synchronized void instantiateServiceInstance(); @Override synchronized ListenableFuture<Void> closeServiceInstance(); @Override ServiceGroupIdentifier getIdentifier(); @Override synchronized void close(); void setDataBroker(DataBroker dataBroker); void setClusteringServiceProvider(ClusterSingletonServiceProvider clusteringServiceProvider); void setRpcProviderService(RpcProviderService rpcProviderService); static final ServiceGroupIdentifier IDENTIFIER; }