默认为content\u类型的应用程序/json,覆盖了DefaultExceptionStrategy中的isFatal

我不想要求我的客户提供content\u类型的应用程序/json,而只是默认设置。我让它工作了。

我还尝试结合另一个示例来实现ConditionalRejectingErrorHandler中的自定义isFatal(Throwable t)。我可以让我的自定义错误处理程序启动,但它似乎再次需要content\u type属性。我想不出如何让他们俩同时工作。

有什么想法吗?

以下成功运行,不需要content\u类型 编辑:下面的代码没有像我想的那样工作。队列中具有属性content\u type application/json的旧消息必须已被拉入

 @EnableRabbit
 @Configuration
 public class ExampleRabbitConfigurer implements 
 RabbitListenerConfigurer {

@Value("${spring.rabbitmq.host:'localhost'}")
private String host;

@Value("${spring.rabbitmq.port:5672}")
private int port;

@Value("${spring.rabbitmq.username}")
private String username;

@Value("${spring.rabbitmq.password}")
private String password;

@Autowired
private MappingJackson2MessageConverter mappingJackson2MessageConverter;

@Autowired
private DefaultMessageHandlerMethodFactory messageHandlerMethodFactory;

@Bean
public MappingJackson2MessageConverter mappingJackson2MessageConverter() {
   return new MappingJackson2MessageConverter();
}

@Bean
public DefaultMessageHandlerMethodFactory messageHandlerMethodFactory() {
   DefaultMessageHandlerMethodFactory factory = new DefaultMessageHandlerMethodFactory();
   factory.setMessageConverter(mappingJackson2MessageConverter);
   return factory;
}

@Override
public void configureRabbitListeners(final RabbitListenerEndpointRegistrar registrar) {
   registrar.setMessageHandlerMethodFactory(messageHandlerMethodFactory);
}

下面的代码用于覆盖ConditionalRejectingErrorHandler中的isFatal()。SimpleRabbitListenerContainerFactory。setMessageConverter()似乎应该与DefaultMessageHandlerMethodFactory具有相同的用途。setMessageConverter()。显然情况并非如此。

 @EnableRabbit
 @Configuration
 public class ExampleRabbitConfigurer {

@Value("${spring.rabbitmq.host:'localhost'}")
private String host;

@Value("${spring.rabbitmq.port:5672}")
private int port;

@Value("${spring.rabbitmq.username}")
private String username;

@Value("${spring.rabbitmq.password}")
private String password;

@Autowired
ConnectionFactory connectionFactory;

@Autowired
Jackson2JsonMessageConverter jackson2JsonConverter;

@Autowired
ErrorHandler amqpErrorHandlingExceptionStrategy;

@Bean
public Jackson2JsonMessageConverter jackson2JsonConverter() {
    return new Jackson2JsonMessageConverter();
}

@Bean
public ErrorHandler amqpErrorHandlingExceptionStrategy() {
    return new ConditionalRejectingErrorHandler(new AmqpErrorHandlingExceptionStrategy());
}

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setMessageConverter(jackson2JsonConverter);
    factory.setErrorHandler(amqpErrorHandlingExceptionStrategy);
    return factory;
}


public static class AmqpErrorHandlingExceptionStrategy extends ConditionalRejectingErrorHandler.DefaultExceptionStrategy {

    private final Logger LOGGER = org.slf4j.LoggerFactory.getLogger(getClass());

    @Override
    public boolean isFatal(Throwable t) {

        if (t instanceof ListenerExecutionFailedException) {
            ListenerExecutionFailedException lefe = (ListenerExecutionFailedException) t;
            LOGGER.error("Failed to process inbound message from queue "
                    + lefe.getFailedMessage().getMessageProperties().getConsumerQueue()
                    + "; failed message: " + lefe.getFailedMessage(), t);
        }
        return super.isFatal(t);
    }

}