doReturn(Mockito.mock(ClusterSingletonServiceRegistration.class)).when(this.clusterSingletonServiceProvider)
.registerClusterSingletonService(any(ClusterSingletonService.class));
}
@After
public void tearDown() {
<BUG>this.dispatcher.close();
this.worker.shutdownGracefully().awaitUninterruptibly();
this.boss.shutdownGracefully().awaitUninterruptibly();
this.mappingService.close();</BUG>
this.ribActivator.close();

doReturn(Mockito.mock(ClusterSingletonServiceRegistration.class)).when(this.clusterSingletonServiceProvider)
.registerClusterSingletonService(any(ClusterSingletonService.class));
}
@After
public void tearDown() {
this.dispatcher.close();
if (!Epoll.isAvailable()) {
this.worker.shutdownGracefully().awaitUninterruptibly();
this.boss.shutdownGracefully().awaitUninterruptibly();
}
this.mappingService.close();
this.ribActivator.close();
