我使用Spring,Spring-Websocket,STOMP作为我的应用程序,RabbitMQ作为代理.我需要将通过RabbitMQ传递的所有消息记录到Postgresql表中.
我知道我可以在Spring编写@MessageMapPing并在那里登录,但我的问题是有些客户端通过MQTT协议直接与RabbitMQ通信,Spring还不支持它(https://jira.spring.io/browse/SPR-12581).此外,浏览器客户端使用STOMP协议通过Spring与RabbitMQ进行通信.
RabbitMQ允许使用Firehose跟踪器跟踪所有消息.如何从Spring正确收听amq.rabbitmq.trace主题?或者我是否需要将单独的Java应用程序编写为消费者?
最佳答案Spring AMQP适合你!您将某个自定义队列绑定到具有适当模式的amq.rabbitmq.trace(例如,发布.#),并配置SimpleMessageListenerContainer以接收来自该队列的消息.
即使使用非常简单的配置也可以完成它:@EnableRabbit和@RabbitListener在一些POJO方法上.无论如何,绑定@Bean必须在那里将你的队列附加到该交换.
总结以上是内存溢出为你收集整理的如何在Spring中正确获取RabbitMQ中的所有队列消息?全部内容,希望文章能够帮你解决如何在Spring中正确获取RabbitMQ中的所有队列消息?所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)