MaterialUpdateListenerFactoryTest.java 文件源码

@Test
public void shouldCreateCompetingConsumersForSuppliedQueue() throws Exception {
    when(systemEnvironment.getNumberOfMaterialCheckListener()).thenReturn(NUMBER_OF_CONSUMERS);

    MaterialUpdateListenerFactory factory = new MaterialUpdateListenerFactory(topic,configTopic, queue, configQueue,
            materialRepository, systemEnvironment, healthService, diskSpaceMonitor,
            transactionTemplate, dependencyMaterialUpdater, scmMaterialUpdater,
            packageMaterialUpdater, pluggableSCMMaterialUpdater, materialExpansionService, mduPerformanceLogger,
            dependencyMaterialQueue, null);
    factory.init();

    verify(queue, new Times(NUMBER_OF_CONSUMERS)).addListener(any(GoMessageListener.class));
}