问题描述
服务器停止后获取如下日志
2020-04-01 01:34:44.353 INFO ABC --- [ Thread-2] o.s.a.r.l.SimpleMessageListenerContainer :关闭被忽略 - 容器已经不活动
SimpleMessageListenerContainer 代码块
@Bean
public RabbitListenerContainerFactory<SimpleMessageListenerContainer> rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setAckNowledgeMode(AckNowledgeMode.NONE);
factory.setAfterReceivePostProcessors(m -> {
m.getMessageProperties().setContentType("text/plain");
return m;
});
return factory;
}
消费者类如下
@Component
public class ConsumerOne {
@RabbitListener(queues = "queue_one"},containerFactory = "rabbitListenerContainerFactory")
public void onMessage(String message) {
try {
LOGGER.info(message);
} catch (Exception e) {
LOGGER.error("EXCEPTION ",message,e);
}
}
}
我有多个用于多个队列的消费者类。提前致谢