不能存根SimpleMessageListenerContainer isActive方法[Spring AMQP Rabbit]

Question

@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));
    }
}

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

Answer 1

Mockito不能模拟final方法(isactive()是final)。

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

也就是说，嘲笑监听器容器是相当不寻常的；它是一段复杂的代码；也许你能准确地解释一下你想测试的是什么？