spring-rabbit 相关问题

使用RabbitMQ进行基于AMQP的消息传递的Spring组件。

RabbitMQ - 在使用参数'x-expires'删除队列后将消息转发到另一个队列

我对 rabbitMQ 配置有疑问。我想在 RabbitListener(失去网络连接或有人关闭应用程序)关闭后 20 分钟将所有消息从队列转发到另一个队列。 ...

回答 1 投票 0

使用Rabbit MQ的Spring应用程序中的声明符

我正在使用spring aqmp 2.2.6版本来创建多个绑定到一个话题交换。我从讨论和参考文档中了解到,我可以使用declarables.Spring AMQP: Creating ...

回答 1 投票 0

创建一个库,让兔子春豆创建起来

我正在创建一个消息总线jar,它连接到不同的MQ broker,如Rabbit MQ。这个jar将被许多应用程序用来发送和接收来自Rabbit的消息。当发送消息是...

回答 1 投票 0

spring-boot-starter-amqp无法使用仅具有写许可权的用户凭据将消息发送到AMQP交换

我正在尝试从springboot应用程序向RabbitMQ发送消息。使用的依赖项(springboot和amqp): org.springframework.boot&...

回答 1 投票 0

RabbitMQ Atleast一次发送配置时间间隔

我已阅读到,如果某个使用者接受了一条消息,但未确认在给定的时间范围内已成功处理该消息,那么将向另一个使用者提供相同的消息以保证...

回答 1 投票 0

Spring AMQP在队列Bean上设置prefetchCount

我如何为此队列使用者设置prefetchCount? @Bean public Queue eventQueue(AmqpAdmin amqpAdmin){队列队列= QueueBuilder.durable(EVENT_QUEUE_NAME)... ....

回答 1 投票 0

如何在RabbitMQ Spring框架中使用“声明的对象”动态创建绑定

我的代码获取用户的输入,该输入是路由键的列表,并使用它们将交换机绑定到队列。我使用Declarables为每个路由键生成绑定。问题是,...

回答 1 投票 0

Spring AMQP获取现有队列名称和参数

我们在生产中有一个队列,其中通过应用程序设置了消息TTL。现在,我们要更改消息TTL并通过Rabbit CTL附加策略,而不是在应用程序中进行设置。片段:地图

回答 1 投票 0

Spring-AMQP-基于消息头的路由

根据文档:https://docs.spring.io/spring-amqp/docs/2.2.5.RELEASE/reference/html/#async-annotation-driven我们可以基于已转换的消息使用不同的处理程序类类型...

回答 1 投票 0

带TLS的Spring Boot和Rabbitmq(AMQP 1.0)

我正在寻找一个通过TLS1.2连接到Rabbitmq(或通用AMQP 1.0服务器)的春季启动示例,可能使用一些已经可用的插件。预先非常感谢您的帮助最好...

回答 1 投票 0

SimpleMessageListenerContainer批量消息处理

我有一个传入数据流,作为单个消息发送到RabbitMQ。我想将它们发送到需要一批消息的服务。我需要在...

回答 1 投票 1

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

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

回答 1 投票 0

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

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

回答 1 投票 0

DirectMessageListenerContainer和SimpleMessageListenerContainer与Rabbit通道的关系

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

回答 1 投票 0

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

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

回答 1 投票 0

禁用Spring Cloud Rabbit进行测试

我使用: org.springframework.cloud spring-cloud-starter-stream-rabbit 3 .... ]]

回答 1 投票 0

Spring AMQP Rabbit监听器在“ ApplicationReadyEvent”之前触发

在Spring应用程序启动时,我想在Redis中查找一个值,根据该值,我想关闭或保留我拥有的消息侦听器。也可以不...

回答 1 投票 0

Spring AMQP-发布者确认发布到不存在的队列时确认的返回结果

如果我使用发布者确认并在RabbitMQ上返回回调,则永远不会收到返回的消息。从Spring AMQP文档:-发布到交易所,但没有匹配的目标队列。 -发布...

回答 1 投票 0

Rabbitmq消息到期

到期后邮件不会丢失。使用spring-rabbit java客户端,我正在发送带有设置为expiration:10000的标头的消息。供参考的是消息...

回答 1 投票 0


最新问题
© www.soinside.com 2019 - 2025. All rights reserved.