Retryable ne fonctionne pas dans un thread séparé

Question

J'essaie de tester si mon appel de méthode a été réessayé plusieurs fois si une exception a lieu. Et si j'appelle la méthode directement, ça fonctionne bien. Mais si je l'appelle dans un fil séparé, ma méthode de test échoue, elle ne voit aucune tentative de nouvelle tentative. Voilà mes méthodes:

public class MyClass { 
     @Inject 
     private ServiceClass service; 

     @Retryable(value = {Exception.class}, maxAttempts = 5, backoff = @Backoff(delay = 30000)) 
     public void retryMethod(Integer id, double dId) 
     { 
      Thread remoteDIUpdater = new Thread(() -> { 
      service.updateIndex(id, dId); 
      } 
      ); 
     remoteDIUpdater.setDaemon(true); 
     remoteDIUpdater.setName("RemoteDIUpdaterThread"); 
     remoteDIUpdater.start(); 
     } 

     @Recover 
     public void recover(Exception ex, Integer id, double dId) 
     { 
      logger.error("Error", ex); 
     } 
} 

Et voici ma classe de test:

public class TestClass 
{ 
    @Inject 
    @InjectMocks 
    private MyClass myClass; 

    @Mock  
    private private ServiceClass service; 

    @Test 
    public void testMethod() 
    { 
     Integer id = 1; 
     double dId = 2d; 
     doThrow(Exception.class).when(service).retryMethod(id, dId); 
     myClass.updateBetDangerIndex(betId, dangerIndex); 
     verify(service, Mockito.times(5)).retryMethod(null, id, iId); 
    } 

} 

Peut-être que ma méthode de test est faux. MAIS si j'appelle ma méthode simplement comme ceci (thread withot):

@Retryable(value = {Exception.class}, maxAttempts = 5, backoff = @Backoff(delay = 30000)) 
      public void retryMethod(Integer id, double dId) 
      {    
       service.updateIndex(id, dId);    
      } 

, ma méthode d'essai fonctionne bien. Quelle est l'erreur?

Answer 1

Vous devez probablement ajouter Thread.join() après remoteDIUpdater.start() pour empêcher le thread principal de se terminer avant votre thread.