使用RabbitMQ进行基于AMQP的消息传递的Spring组件。
Spring AMQP/RabbitMQ - java.net.SocketException：连接被对等方重置（写入失败）
我在 Kubernetes 集群中有一个 RabbitMQ 服务器，我使用具有默认设置和 RabbitTemplate 类的 Spring AMQP 连接到该服务器。 我在发送方 Spring Boot Microser 中有一个预定的方法...
如果 RabbitMQ 服务器暂时不可用，如何重试启动 Apache Camel RabbitMQ 消费者路由器
我有一个简单的 Apache Camel 路线 from("spring-rabbitmq:myExchange?routingKey=foo&bridgeErrorHandler=true") .log("来自 RabbitMQ: ${body}"); 示例项目...
如果 RabbitMQ 服务器暂时不可用，如何重新尝试启动 Apache Camel RabbitMQ 消费者路由器
我有一个简单的 Apache Camel 路线 from("spring-rabbitmq:myExchange?routingKey=foo&bridgeErrorHandler=true") .log("来自 RabbitMQ: ${body}"); 示例项目...
将 Spring Cloud Connector 迁移到 Cloudfoundry 中的 java-cfenv 导致 Rabbit-MQ 服务的 TLS 失败
在将 Spring Cloud Services 从 2.4.1 升级到 3.5.5 时，我们发现应用程序无法连接到 Cloud Foundry 中的 Rabbit MQ 服务。它抛出以下异常：- c.r.客户...
我正在尝试为 JUnit 中的 RabbitAdmin 类创建一个模拟对象。 @Mock RabbitAdmin rabbitAdmin； @InjectMocks MyOriginalClass classObj; 以上是我声明的内容。 Mockito.when(rabbitAdmin.
我收到如下消息，其中包含 2 个 HashMap（inputMap 和 outputMap）。使用 ObjectMapper 的方法是否正确？ 示例消息： 在 RabbitMQ 中： {"ORCH_KEY":{"inputMap":{},"
我队列的第一条消息总是失败。 从第二个开始，一切正常！ 不确定这是否可读： 创建新连接：rabbitConnectionFactory#1b940034:0/SimpleConn...
在 Spring Cloud Stream 中使用多个 rabbitmq 绑定器时忽略绑定路由键
我正在尝试将一个小型 Spring Cloud Stream 应用程序连接到两个不同的 RabbitMQ 系统。 对于这两个系统，我想将流输入绑定到现有交换，指定路由键。小...
Spring Cloud Stream 从 DLQ 消息中删除 x-exception-stacktrace
我们尝试从 DLQ 消息中删除“x-exception-stacktrace”，以使重新发布消息的足迹更小。 我们使用默认的弹簧机制 春天： 云： 压力...
从 XML 到 Java 的 Spring AMQP 应用程序配置
我正在努力将 RabbitMQ 应用程序配置从 XML 重写为 Java。可悲的是，一旦执行代码，就会出现非常普遍的错误： org.springframework.amqp.rabbit.listener.exception.
目前，我正在使用 spring-boot-starter-amqp 模块，可以使用注解@RabbitListener 在后台读取消息，我如何才能从队列中消费固定数量的消息...
RabbitMQ - 在使用参数'x-expires'删除队列后将消息转发到另一个队列
我对 rabbitMQ 配置有疑问。我想在 RabbitListener（失去网络连接或有人关闭应用程序）关闭后 20 分钟将所有消息从队列转发到另一个队列。 ...
我正在使用spring aqmp 2.2.6版本来创建多个绑定到一个话题交换。我从讨论和参考文档中了解到，我可以使用declarables.Spring AMQP: Creating ...
我正在创建一个消息总线jar，它连接到不同的MQ broker，如Rabbit MQ。这个jar将被许多应用程序用来发送和接收来自Rabbit的消息。当发送消息是...
spring-boot-starter-amqp无法使用仅具有写许可权的用户凭据将消息发送到AMQP交换
我正在尝试从springboot应用程序向RabbitMQ发送消息。使用的依赖项（springboot和amqp）： org.springframework.boot＆...
我已阅读到，如果某个使用者接受了一条消息，但未确认在给定的时间范围内已成功处理该消息，那么将向另一个使用者提供相同的消息以保证...
Spring AMQP在队列Bean上设置prefetchCount
我如何为此队列使用者设置prefetchCount？ @Bean public Queue eventQueue（AmqpAdmin amqpAdmin）{队列队列= QueueBuilder.durable（EVENT_QUEUE_NAME）... ....
如何在RabbitMQ Spring框架中使用“声明的对象”动态创建绑定
我的代码获取用户的输入，该输入是路由键的列表，并使用它们将交换机绑定到队列。我使用Declarables为每个路由键生成绑定。问题是，...
我们在生产中有一个队列，其中通过应用程序设置了消息TTL。现在，我们要更改消息TTL并通过Rabbit CTL附加策略，而不是在应用程序中进行设置。片段：地图
根据文档：https://docs.spring.io/spring-amqp/docs/2.2.5.RELEASE/reference/html/#async-annotation-driven我们可以基于已转换的消息使用不同的处理程序类类型...