spring-amqp 相关问题

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

Spring Boot - Rabbit 自定义 ConnectionFactory

Spring AMQP/Rabbit 中是否有可用的公共实用方法来创建自定义 Rabbit 连接工厂。截至目前，我正在使用以下代码 @Bean(名称 = "rp1") @

spring-boot spring-amqp

回答 2 投票 0

如何在发布到 dlq 之前向 amqp 消息添加标头？

我正在使用 spring-amqp 和死信队列来处理失败的消息，但我想增加每次重试的 ttl（如指数退避）。我尝试在自定义电子邮箱中获取消息...

spring-amqp

回答 1 投票 0

spring.rabbitmq.publisher-returns=true 和 spring.rabbitmq.template.mandatory=true 有什么区别？

spring.rabbitmq.publisher-returns=true 和 spring.rabbitmq.template.mandatory = true 有什么区别？当这两个配置之一设置为 true 时，当消息发送到

amqp spring-amqp

回答 1 投票 0

RabbitMQ - 将消息发送到队列中的特定消费者

这是场景 - 有多个应用程序服务器。浏览器可以通过 websocket 连接到任何应用程序服务器。应用程序服务器（消费者）都在监听特定的队列。一旦网络如此...

rabbitmq spring-amqp spring-rabbit

回答 3 投票 0

在 Spring Cloud 配置服务器中转义登录

我有spring cloud配置服务器，它为rabbit提供密码。密码包含“@”。当我使用 static appliation.yaml 运行应用程序时，我必须用 '' 包围值春天：兔子MQ：

rabbitmq spring-cloud spring-amqp spring-rabbit spring-cloud-config

回答 1 投票 0

spring-boot-starter-amqp 依赖导致 CglibAopProxy 在调用 CachingConnectionFactory.createConnection() 时抛出 AmqpException

我正在尝试将rabbitmq嵌入到Spring Boot应用程序中。我遵循了互联网上的各种教程。使用的spring boot版本是V2.7.14。我的 POM 中有 spring-boot-starter-amqp

spring-boot rabbitmq spring-amqp

回答 1 投票 0

如何配置Spring AMQP在监听器抛出AmqpRejectAndDontRequeueException时不重新排队？

我目前有一个 Spring Boot 应用程序配置为使用 spring-boot-starter-amqp 2.1.5.RELEASE。我已在 yaml 中将其配置为重试：兔子MQ：听众：简单的：重新...

spring-amqp spring-rabbit spring-retry

回答 1 投票 0

RabbitMQ 消息在抛出 AmqpRejectAndDontRequeueException 后仍然重试

我有一个简单的 Spring Boot 应用程序，其中有以下 RabbitMQ 设置（spring-boot-starter-amqp 版本是 2.7.0）：春天：兔子MQ：主机：本地主机端口：5672 虚拟...

spring-boot rabbitmq spring-amqp dead-letter retry-logic

回答 2 投票 0

Spring amqp 死信交换与多个队列绑定

在我的应用程序中，使用两个队列，它们与一个带有密钥的交换器绑定.. 与此键正则表达式匹配的任何消息都将进入两个队列。案例 2：我正在尝试实施...

java spring-boot rabbitmq spring-amqp spring-rabbit

回答 2 投票 0

如何在 Spring Boot 中将当前的 SecurityContext 传播到我的 @RabbitListener？

用例：我想要一个 REST API，它将使用 RabbitMQ/AMQP 在系统中触发一个事件，并且我想要将当前登录用户的 SecurityContext 传播到该事件，或者...

spring spring-security spring-amqp

回答 1 投票 0

使用 springboot 的 Rabbitmq RPC（请求-回复）

我想使用 RabbitMQ 实现微服务通信的请求-回复模式。然而，问题是每个内部调用都会创建一个新队列，并且默认情况下，队列大小在

java spring-boot rabbitmq amqp spring-amqp

回答 1 投票 0

单个队列，多个@RabbitListener但服务不同

是否可以有一个@RabbitListener，例如： @RabbitListener（队列= STORAGE_REQUEST_QUEUE_NAME）公共 FindApplicationByIdResponse findApplicationById（FindApplicationByIdRequest 请求...

rabbitmq amqp spring-amqp

回答 1 投票 0

如何拦截RabbitMQ中的身份验证错误

我们公司有一项政策，当我们连续验证失败超过3次时，帐户将被锁定。在 Spring Boot 服务中，我们使用 RabbitMQ 进行设置，登录机制...

spring-boot rabbitmq spring-amqp

回答 1 投票 0

在 Spring Boot 中无法解锁 Rabbit Listener 中的 Redisson 锁

我在 Spring Boot 的 rbbit 监听器中有以下代码块。我尝试使用 redisson 获取锁： @RabbitListener（队列= Const.Rabbit.QUEUE_NAME，并发=“1”）公共空间

java spring-boot spring-amqp redisson

回答 1 投票 0

RabbitMQ：多个消费者的循环

项目主要由三部分组成：生产者（设备）通过 MQTT 协议向 Broker 发送数据 RabbitMQ 代理用于应用程序和代理之间通信的消费者（spring AMQP）。（设备 MQTT

rabbitmq amqp spring-amqp spring-rabbit round-robin

回答 1 投票 0

possibleFatalAuthenticationFailure 标志 - 被 AsyncMessageProcessingConsumer 忽略

Spring-AMQP 通过 AMQP-750 添加了 possibleFailureAuthentication 标志。但是，至少在一种情况下，容器可以接收 AuthenticationFailureException 并抛出

spring-amqp

回答 1 投票 0

带有 AMQP 库或 RabbitMQ 库的 Spring Boot RabbitMQ

我开始使用 RabbitMQ 处理消息队列，我很喜欢使用 AMQP，下面是代码，所以我发现当使用 RabbitTemplate 和 amqp.connectionFactory 时，我们不能有 h...

spring spring-boot rabbitmq spring-amqp

回答 1 投票 0

spring-amqp：通道关闭并显示 NACKS RECEIVED 消息

在 RabbitMQ 总线上使用负载较重的 spring-amqp，我们有时会从 org.springframework.amqp.rabbit.connection.CachingConnectionFactory 获取日志：通道关闭：干净通道关闭；

spring-amqp

回答 2 投票 0

如何使用SimpleRetryPolicy从Spring AMQP重试策略中排除特定异常？

我的 Spring AMQP 应用程序中有一个 RabbitListener，并且我正在使用自定义 RabbitListenerFactory 和配置用于消息重试的 SimpleRetryPolicy。但是，我想排除某些例外...

java spring spring-amqp spring-rabbit spring-retry

回答 2 投票 0

Spring amqp - 未找到兼容的身份验证机制 - 服务器提供[]

我正在尝试通过外部身份验证机制（https://github.com/rabbitmq/rabbitmq-auth-mechanism-ssl）将spring boot应用程序连接到rabbit mq。我收到以下错误： org.springframework.amqp.

java spring-boot rabbitmq spring-amqp spring-rabbit

回答 1 投票 0

spring-amqp 相关问题

最新问题