如何解决如何保持 SimpleMessageListenerContainer 处于活动状态,直到使用此容器的所有线程关闭
服务器停止后获取如下日志
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);
}
}
}
我有多个用于多个队列的消费者类。提前致谢
解决方法
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。