如何在Spring中正确获取RabbitMQ中的所有队列消息?
我使用Spring,Spring-Websocket,STOMP作为我的应用程序,RabbitMQ作为代理.我需要将通过RabbitMQ传递的所有消息记录到Postgresql表中. RabbitMQ允许使用Firehose跟踪器跟踪所有消息.如何从Spring正确收听amq.rabbitmq.trace主题?或者我是否需要将单独的Java应用程序编写为消费者? 最佳答案
Spring AMQP适合你!
您将某个自定义队列绑定到具有适当模式的amq.rabbitmq.trace(例如,发布.#),并配置SimpleMessageListenerContainer以接收来自该队列的消息. 即使使用非常简单的配置也可以完成它:@EnableRabbit和@RabbitListener在一些POJO方法上.无论如何,绑定@Bean必须在那里将你的队列附加到该交换. (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |