无法存根 SimpleMessageListenerContainer isActive 方法 [Spring AMQP Rabbit]

问题描述

我正在尝试为切换 SimpleMessageListenerContainer（启动/停止）的 Spring EventListener 创建单元测试。

我要测试的代码：

@Configuration
public class SpringEventsListeners {
    private static CPLocation cpLocation = CPLoggingFactory.createCPLocation(SpringEventsListeners.class);

    private ConfigurationServiceImpl configService;

    //Constructor Injection for Testability.
    public SpringEventsListeners(final ConfigurationServiceImpl configService) {
        this.configService = configService;
    }

    /**
     * Rabbit listeners might be started/stopped after a refresh depending on a property.
     * In case a change is needed,we perform it.
     */
    @EventListener(classes= { ApplicationReadyEvent.class,EnvironmentChangeEvent.class })
    public void handleRabbitListenerToggle() {
        String method = "handleRabbitListenerToggle";
        cpLocation.info(method,"Received refresh event. Determining action.");
        
        boolean shouldActivaterabbit = configService.shouldActivaterabbitListeners();
        for (SimpleMessageListenerContainer container : configService.getAllRabbitSimpleMessageListenerContainers()) {
            if (shouldActivaterabbit && !container.isActive()) {
                container.start();
                cpLocation.info(method,"Starting container: "+Arrays.toString(container.getQueueNames()));
            }
            else if (!shouldActivaterabbit && container.isActive()) {
                container.shutdown();
                cpLocation.info(method,"Shutting down container: "+Arrays.toString(container.getQueueNames()));
            }
        }
    }
    
}

最小测试（什么都不测试）：

@RunWith(MockitoJUnitRunner.class)
public class SpringEventsListenersTests {

    @InjectMocks
    private SpringEventsListeners classUnderTest;

    @Mock
    private ConfigurationServiceImpl mockConfigurationService;

    @Mock
    private SimpleMessageListenerContainer mockSimpleMessageListenerContainer;

    @Test
    public void testToggleTrue() {
        //Given
        given(mockConfigurationService.shouldActivaterabbitListeners()).willReturn(true);
        given(mockConfigurationService.getAllRabbitSimpleMessageListenerContainers()).willReturn(Arrays.asList(mockSimpleMessageListenerContainer));
        given(mockSimpleMessageListenerContainer.isActive()).willReturn(false);
        //When
        classUnderTest.handleRabbitListenerToggle();
        Assert.assertthat(true,is(true));
    }
}

当我在 given(mockSimpleMessageListenerContainer.isActive()).willReturn(false); 上收到 NullPointerException 时，测试不会运行：

java.lang.NullPointerException 在 org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.isActive(AbstractMessageListenerContainer.java:1271) 在 com.cp.order.listener.SpringEventsListenersTests.testToggleTrue(SpringEventsListenersTests.java:36) 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 在 java.lang.reflect.Method.invoke(Method.java:498) 在 org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) 在 org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) 在 org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47) 在 org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) 在 org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325) 在 org.junit.runners.BlockJUnit4ClassRunner.runchild(BlockJUnit4ClassRunner.java:78) 在 org.junit.runners.BlockJUnit4ClassRunner.runchild(BlockJUnit4ClassRunner.java:57) 在 org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) 在 org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) 在 org.junit.runners.ParentRunner.runchildren(ParentRunner.java:288) 在 org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) 在 org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) 在 org.junit.runners.ParentRunner.run(ParentRunner.java:363) 在 org.mockito.internal.runners.DefaultInternalRunner$1.run(DefaultInternalRunner.java:79) 在 org.mockito.internal.runners.DefaultInternalRunner.run(DefaultInternalRunner.java:85) 在 org.mockito.internal.runners.StrictRunner.run(StrictRunner.java:39) 在 org.mockito.junit.MockitoJUnitRunner.run(MockitoJUnitRunner.java:163) 在 org.junit.runner.JUnitCore.run(JUnitCore.java:137) 在 com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68) 在 com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47) 在 com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242) 在 com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)

我还需要断言 .shutdown 或 .start 是在容器上调用的，因此需要对其进行模拟。

解决方法

Mockito 不能模拟 final 方法（isActive() 是最终的）。

您可以使用反射（例如 DirectFieldAccessor）来检查 active 字段。

也就是说，嘲笑侦听器容器是相当不寻常的；它是一段复杂的代码；也许您可以准确解释您要测试的内容？