Wykonanie detektora komunikatu JMS nie powiodło się i nie ustawiono obiektu ErrorHandler

Question

Gdy używam Spring do słuchania wiadomości JMS, otrzymuję powyższy błąd.

Zastanawiasz się, jak dodać moduł obsługi błędów do modułu nasłuchiwania JMS?

Answer 1

Jest nieruchomość na AbstractMessageListenerContainer:

<bean id="listener" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> 
    <property name="errorHandler" ref="someHandler"/> 
    <property name="destinationName" value="someQueue"/> 
    <property name="connectionFactory" ref="connectionFactory"/> 
</bean> 

Gdzie someHandler jest fasola realizacji ErrorHandler:

@Service 
public class SomeHandler implements ErrorHandler { 

    @Override 
    public void handleError(Throwable t) { 
     log.error("Error in listener", t); 
    } 
} 

jednak pamiętać, że zgodnie z documentation:

domyślne zachowanie tego słuchacza wiadomości [...] będzie rejestruje każdy taki wyjątek na poziomie błędu. [...] Jednakże, jeśli obsługa błędów jest konieczna, wówczas każda implementacja strategii ErrorHandler może być dostarczona do metody setErrorHandler (ErrorHandler).

Sprawdź swoje logi, może wyjątek jest już zalogowany?

Answer 2

Bez konfiguracji xml. Zrobiłem następujące w ApplicationContext.

@Bean 
JmsListenerContainerFactory<?> jmsContainerFactory(ConnectionFactory connectionFactory, 
     SomeHandler errorHandler) { 
    SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory(); 
    factory.setConnectionFactory(connectionFactory); 
    factory.setErrorHandler(errorHandler); 
    return factory; 
} 


// From Tomasz answer 
@Service 
public class SomeHandler implements ErrorHandler { 

    @Override 
    public void handleError(Throwable t) { 
     log.error("Error in listener", t); 
    } 
} 

Answer 3

W przypadku gdy stosowane fabryczne:

@Bean 
    public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory connectionFactory, 
      SomeHandler errorHandler) { 
     DefaultJmsListenerContainerFactory factory = 
       new DefaultJmsListenerContainerFactory(); 
     factory.setConnectionFactory(connectionFactory); 
     factory.setErrorHandler(errorHandler); 
     return factory; 
    } 

Answer 4

Lubię to krótkie i słodkie!

@Bean 
JmsListenerContainerFactory<?> jmsContainerFactory(ConnectionFactory connectionFactory) { 
    SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory(); 
    factory.setConnectionFactory(connectionFactory); 
    factory.setErrorHandler(t -> { 
     log.error("Error in listener!", t); 
     }); 
    return factory; 
}