spring-rabbitmq 相关问题

基于AMQP的消息传递的Spring组件。

Json编码的Spring Boot格式Timstamp

[从RabbitMQ获取以下JSON {“ PlateNo”:“ A125”,“ DeviceId”:“ D152”,“ Time”:“ / Date(1584260162000)/”,“ Latitude”:25.59483611111111,“ Longitude”:56.30596666666667,“地址”:“阿联酋富查伊拉迪巴(Dibba)”,“ ...

回答 1 投票 0

Rabit-mq死信交换不起作用,导致无限次重试

我有一个制作人:rabbitTemplate.convertAndSend(QueueConstants.PROVISIONING_EXCHANGE,QueueConstants.PROVISIONING_ROUTING_KEY,message);而我的配置:@Bean Queue organizationProvisioningQueue(){...

回答 1 投票 0

侦听器在重新建立与主机的连接后不会提取数据

首先,我刚刚开始涉足AMQP。我想从队列中消费/提取数据。我使用Spring的库(spring-boot-starter-amqp)来使事情变得更容易。我有一个...

回答 1 投票 0

Spring Batch ItemReader + RabbitMQ-未指定 '队列'

我正在运行2种服务:一种连接到DB并将数据发送到msg代理,另一种应该从Rabbit获取消息并通过批处理将其发送到targetDB。我有相同的...

回答 1 投票 0

Spring cloud stream Rabbitmq绑定器-Spring Cloud函数错误处理

我正在使用具有春天云功能的春天云流兔子活页夹,并定义如下的监听器:public Function ,Flux > foo(){//一些代码} I ...

回答 1 投票 2

如何处理spring boot stomp websocket订阅端点来授权用户

我们已经安全地为我们的项目成功开发了webosocket + stomp + rabbitmq。尽管我们在解决以下问题时遇到了一些问题,但它仍然可以正常工作:此...

回答 1 投票 0

将自定义标题添加到Spring Cloud Stream(使用Spring Reactor)

作为Spring Reactor的新手,我正在尝试使用Spring云流(使用rabbitMQ)来流数据。在将消息发送到队列之前,我需要添加一些自定义标头。我的spring-cloud -...

回答 1 投票 0

如何通过配置禁用兔子健康检查

我想在默认的RabbitMockConfiguration中禁用兔子健康检查。我们有一个通过@Import导入的配置。不幸的是,该配置不会阻止健康...

回答 2 投票 0

SimpleMessageListenerContainer无法正确调用消息处理程序

我正在尝试在Spring Boot应用程序中监听RabbitMq队列。在我的RabbitConfig.java文件中,我有以下bean:// RabbitConfig.java // ...排队,交换,绑定bean等@Bean ...

回答 1 投票 0

RabbitMQ-在删除队列之前移动消息

使用RabbitMQ 3.7.16,带有spring-amqp 2.2.3版本。多个客户端将消息发布到我们RabbitMQ服务器中的主题交换。为了分别按...

回答 1 投票 1

spring amqp兔子-默认情况下没有接收器

我正在构建两个应用程序,一个用于将消息发布到RabbitMq,另一个用于使用RabbitMq的消息。我从spring的rabbitmq入门开始。问题:...

回答 1 投票 0

Spring Rabbit Listener关闭处理程序或没有重新传递标志的返回消息

我有一个不寻常的场景,如果我的应用程序在处理过程中被正常关闭(例如,自动缩放),我不希望将消息与重新传递的标志一起发送回队列。]

回答 1 投票 0

DirectMessageListenerContainer和SimpleMessageListenerContainer与Rabbit通道的关系

[当使用consumersPerQueue属性为25的DirectMessageListenerContainer时,我注意到每个侦听器容器的已订阅队列都创建了25个兔子通道。兔子频道快速计数...

回答 1 投票 0

仅在存在交换的情况下如何使用Spring AMQP绑定到主题?

我需要将队列绑定到主题交换,但是:仅当主题存在时如果主题存在,请使用现有设置(例如,持久性,自动删除等)原因是,我需要第三方应用程序。 。

回答 1 投票 0

正确使用SpringRabbit DirectMessageListenerContainer和setConsumersPerQueue属性

我使用DirectMessageListenerContainer来监听各个队列,因为它会为每个队列创建一个使用者,如果说“ queue1”的消息需要花一些时间来处理,则可以防止队列不足,而...

回答 1 投票 0

如何在春季启动中使用循环创建多个(20-30)RabbitMQ队列

无济于事:带有Spring Boot的多个Rabbitmq队列

回答 1 投票 0

RabbitMQ对Spring的直接答复问题

我正在处理一个将消息发送到服务器的应用程序,然后修改给定消息并使用Direct Reply-to将其发送回amq.rabbitmq.reply-to队列。我已经按照教程进行了操作...

回答 1 投票 0

SpringAMQP-重试/重新发送消息dlx

我正在尝试通过DLX使用重试机制。因此,基本上,我想发送一条消息3次,然后停止并在dlx队列上停止此消息;我所做的:创建绑定到...

回答 1 投票 0

Spring AMQP在使用@SendTo发送时失去连接时如何访问响应消息

我们有一个微服务,该微服务使用@RabbitListener消耗一条消息并将数据持久存储到数据库中,在成功处理消息后生成响应,并使用@sendTO将其发送到不同的...

回答 1 投票 0

如何使用RabbitMq管理员界面记录队列

我们有一个要求RabbitMq管理员需要有关已定义和使用的队列的信息。他们需要诸如...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.