@Test
public void testListeners() throws Exception {
Future<PentahoCacheProvidingService> serviceFuture;
factory.init();
verify( bundleContext ).addServiceListener( serviceListenerCaptor.capture(), argThat( matchesFilter ) );
serviceFuture = factory.getProviderService( MOCK_PID );
assertThat( serviceFuture.isDone(), is( true ) );
assertThat( serviceFuture.get( 1, TimeUnit.SECONDS ), is( providingService ) );
ServiceListener serviceListener = serviceListenerCaptor.getValue();
serviceListener.serviceChanged( new ServiceEvent( ServiceEvent.UNREGISTERING, serviceReference ) );
serviceFuture = factory.getProviderService( MOCK_PID );
assertThat( serviceFuture.isDone(), is( false ) );
serviceListener.serviceChanged( new ServiceEvent( ServiceEvent.REGISTERED, serviceReference ) );
serviceFuture = factory.getProviderService( MOCK_PID );
assertThat( serviceFuture.isDone(), is( true ) );
assertThat( serviceFuture.get( 1, TimeUnit.SECONDS ), is( providingService ) );
}
PentahoCacheManagerFactoryTest.java 文件源码
java
阅读 21
收藏 0
点赞 0
评论 0
项目:pentaho-osgi-bundles
作者:
评论列表
文章目录