Assertion Fehler beim Ausführen von Test mit LatchCountDownAndCallRealMethodAnswer von RabbitMQ

Question

Ich habe einen Listener-Test, wo ich eine Nachricht in einem parallelen Thread und überprüfen Sie mit LatchCountDownAndCallRealMethodAnswer, ob alle erfolgreich verarbeitet wurden. Wenn Sie den Test alleine ausführen, funktioniert es einwandfrei. Wenn Sie jedoch alle anderen Tests zusammen ausführen, schlägt dies fehl, weil der Zähler nicht auf Null verlassen werden konnte. Der Listener hat die Nachricht jedoch normal empfangen und verarbeitet. Hat jemand irgendwelche Ideen?

My Test Klasse

@RunWith(SpringRunner.class) 
@SpringBootTest 
@RabbitListenerTest 
@ActiveProfiles("test") 
public class EventListenerTest { 

    EventListener eventListener; 

    @Autowired 
    protected RabbitListenerTestHarness harness; 

    @Autowired 
    private EventStoreRepository repository; 

    @SpyBean 
    private DomainEventPublisher publisher; 

    @Before 
    public void setUp() { 
     MockitoAnnotations.initMocks(this); 
     DomainRegister.setDomainEventPublisher(publisher); 
     eventListener = this.harness.getSpy("eventListenerId"); 
    } 

    @Test 
    public void storeEventsListenerTest() throws Exception { 

     LatchCountDownAndCallRealMethodAnswer answer = new LatchCountDownAndCallRealMethodAnswer(1); 
     doAnswer(answer).when(eventListener).storeEvents(any(BalanceReserved.class)); 

     publisher.publish(new BalanceReserved("12233", 150.0, BigDecimal.ZERO), ""); 

     assertTrue(answer.getLatch().await(10, TimeUnit.SECONDS)); 

     verify(eventListener, times(1)).storeEvents(any(BalanceReserved.class)); 
    } 

    @After 
    public void tearDown() { 
     DomainRegister.setDomainEventPublisher(null); 
     reset(eventListener); 
     repository.deleteAll(); 
    } 

} 

Fehler

java.lang.AssertionError 

Answer 1

Wenn Sie andere Tests haben die gleiche Warteschlange verwenden, müssen Sie für jeden Test des Anwendungskontext schließen, so dass der Zuhörer-Tests gestoppt werden. Das Spring Test-Framework speichert den Anwendungskontext standardmäßig zur Wiederverwendung zwischen. Dies führt dazu, dass andere Tests Nachrichten "stehlen".

Fügen Sie zu jeder Testklasse @DirtiesContext hinzu, die @RabbitListener s verwendet, um dem Testframework mitzuteilen, dass der Kontext beendet werden soll.