+
+ doAnswer(new Answer<Filter>() {
+ @Override
+ public Filter answer(InvocationOnMock invocation) {
+ String str = invocation.getArgumentAt(0, String.class);
+ Filter mockFilter = mock(Filter.class);
+ doReturn(str).when(mockFilter).toString();
+ return mockFilter;
+ }
+ }).when(mockedContext).createFilter(anyString());
+ doNothing().when(mockedContext).addServiceListener(any(ServiceListener.class), anyString());
+
+ setupMockService(EventLoopGroup.class);
+ setupMockService(Timer.class);
+ }
+
+ private void setupMockService(Class<?> serviceInterface) throws Exception {
+ ServiceReference<?> mockServiceRef = mock(ServiceReference.class);
+ doReturn(new ServiceReference[]{mockServiceRef}).when(mockedContext).
+ getServiceReferences(anyString(), contains(serviceInterface.getName()));
+ doReturn(mock(serviceInterface)).when(mockedContext).getService(mockServiceRef);