RabbitMQからLatchCountDownAndCallRealMethodAnswerでテストを実行しているときにアサーションエラーが発生しました

Question

私はリスナーテストを行っています。ここでは、並列スレッドにメッセージを投稿し、すべてが正常に処理された場合はLatchCountDownAndCallRealMethodAnswerで確認します。テストを単独で実行すると完全に動作しますが、他のすべてのテストを一緒に実行すると、カウンタがゼロにならないために失敗しますが、リスナーはメッセージを正常に受信して処理します。誰にもアイデアはありますか？

私のテストクラス

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

} 

エラー

java.lang.AssertionError 

Answer 1

あなたが同じキューを使用して他のテストを持っている場合は、テストのリスナーが停止しているように、各テストのためのアプリケーションコンテキストをシャットダウンする必要があります。デフォルトでは、Spring Testフレームワークは再利用のためにアプリケーションコンテキストをキャッシュします。これにより、他のテストでメッセージを "盗む"ことができます。

@DirtiesContextを追加して、それぞれのテストクラスに@RabbitListenerを使用して、テストフレームワークにコンテキストをシャットダウンするように指示します。