分类导航

程序问答发布时间：2022-06-01 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了无法存根 SimpleMessageListenerContainer isActive 方法 [Spring AMQP Rabbit]，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决无法存根 SimplemessageListenerContainer isActive 方法 [Spring AMQP Rabbit]？

开发过程中遇到无法存根 SimplemessageListenerContainer isActive 方法 [Spring AMQP Rabbit]的问题如何解决？下面主要结合日常开发的经验，给出你关于无法存根 SimplemessageListenerContainer isActive 方法 [Spring AMQP Rabbit]的解决方法建议，希望对你解决无法存根 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)