Falló la ejecución del detector de mensajes JMS y no se configuró el Manejador de errores

Question

Cuando uso Spring para escuchar mensajes JMS, recibí el error anterior.

Me pregunto cómo agregar un manipulador de errores en el agente de escucha JMS?

Answer 1

Hay una propiedad en 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> 

Dónde someHandler es un grano de implementar ErrorHandler:

@Service 
public class SomeHandler implements ErrorHandler { 

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

Sin embargo tenga en cuenta que de acuerdo con el documentation:

El comportamiento por defecto de este mensaje oyente [...] será registre cualquier excepción en el nivel de error. [...] Sin embargo, si es necesario el manejo de errores, se puede proporcionar cualquier implementación de la estrategia ErrorHandler al método setErrorHandler (ErrorHandler).

Eche un vistazo a sus registros, tal vez la excepción ya está registrada?

Answer 2

Sin la configuración xml. Hice lo siguiente en 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

En caso cuando se utiliza por defecto de fábrica:

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

Answer 4

me gusta corto y dulce!

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