spring-rabbit 相关问题

RabbitMQ同步消息处理与异步两个队列

将RabbitMQ与Java Spring结合使用，是否可以执行同步等待，以确保发送到第一个队列的消息在被外部服务处理后添加到第二个队列...

使用RabbitMQ tut1教程时无法让rabbitmq发送者打印消息

我在这里有这个项目的 github 存储库的链接：https://github.com/luiz-miotto/rabbitmqTut1v4 我一直在尝试使用

RabbitMQ 消息显示在交换中，但队列为空

我正在练习Spring boot RabbitMQ。正如我在问题中提到的，我对队列有一些问题。我认为我以正确的方式配置了 RabbitMQ。这是我的配置文件； @配置 公开课

在javarabbitmq中获取“c.r.c.impl.ForgivingExceptionHandler：发生意外的连接驱动程序错误（异常消息：连接重置）”

使用rabbitmq运行java项目时出现“c.r.c.impl.ForgivingExceptionHandler：发生意外的连接驱动程序错误（异常消息：连接重置）” Java 版本 -...

无法连接Spring AMQP / Rabbit MQ：org.springframework.amqp.AmqpConnectException：java.net.ConnectException：连接被拒绝：connect

我是 Spring AMQP / Rabbit MQ 的新手。 我在我的项目中使用 Spring AMQP / Rabbit MQ。运行tomcat后遇到以下错误： org.springframework.amqp.rabbit.listener.

在 TestSuite 中模拟 AMQPTemplate

我正在将 JUnits 作为 TestSuite 运行。 JUnit 类之一用于测试将消息发布到 RabbitMQ 的代码。我应该模拟代码以将消息发布到 MQ。怎么会...

Spring amqp RetryCache 抛出 AmqpRejectAndDontRequeueException 时未清除

我有一个简单的 Rabbit 侦听器，它总是抛出 AmqpRejectAndDontRequeueException （以测试侦听器是否可以处理多个无效消息）。 配置是： @RabbitListener( id = 测试配置。

将 JsonComponent 与 RabbitListener 结合使用

我正在尝试使用自定义解串器： @JsonComponent 类 SuffixDeserializer 扩展 JsonDeserializer { 私有最终字符串后缀； SuffixDeserializer(@Value("${s...

微服务架构中RabbitMQ队列、交换属性在哪里定义？

在我当前的项目中，我们使用 Spring Boot 和 RabbitMq 进行一些内部微服务通信。 我们当前正在这两个服务中定义队列属性，用于发布/侦听此...

Apache Camel 的 Spring RabbitMQ 的 RabbitMQ 队列中没有可用消息

当我尝试使用 Apache Camel 组件的 Spring RabbitMQ 将消息从一个队列发布到另一个队列时，目标队列没有收到任何消息。 @成分 公开课 WeatherRoute

spring-rabbit 与 com.rabbitmq 版本兼容性

我在我的应用程序中使用以下rabbitmq依赖项。 org.springframework.amqp 春兔 我在我的应用程序中使用以下rabbitmq依赖项。 <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> <version>1.3.4.RELEASE</version> <exclusions> <exclusion> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>3.3.0</version> </dependency> 现在由于一些严重的漏洞，我必须升级这两个依赖项。 我无法升级<artifactId>spring-rabbit</artifactId>，因为升级需要更改代码。 如果我升级com.rabbitmq应用程序构建和部署都成功。 所以现在我可以升级com.rabbitmq到更高版本（版本应大于4.8.0） 当我们有 spring-rabbit 1.3.4.RELEASE 时，可以将 com.rabbitmq 升级到更高版本（> 4.8.0）吗？ 它不太可能工作，当然也不支持； 1.3.4已经快10年了。 最后一次 1.x 版本是 2 年多前的 1.7.14。 https://spring.io/projects/spring-amqp#support 您应该尽快升级到受支持的版本。 我们还在寻求 amqp-client 5.x 版本与 spring-rabbit 1.3.5 的支持。你能弄清楚这一点吗？

通道关闭：通道错误：reply-code=406，reply-text=PRECONDITION_FAILED - 回复消费者已设置

我正在使用 spring-amqp、spring-rabbit 运行多个测试。我的 Maven 父母是 spring-boot-starter-parent:1.2.3.RELEASE 拉动： 春天兔子：1.4.3.RELEASE spring-amqp：1.4.3.RELEASE 一个...

顺序运行多个 RabbitMQ 队列

我们使用 Spring Boot AMQP 来处理消息。我们有多个队列，其中一些队列依赖于其他队列。我想确保队列等待其他人完成他们的工作。例如...

JMSXGroupId 的 RabbitMQ 解决方法

我知道RabbitMQ不支持JMSXGroupId，从链接来看，这个功能似乎很快就会被合并到RabbitMQ中。是否有任何解决方法可以使用 ex 的组合...

RabbitMQ/Spring AQMP x 队列类型忽略仲裁队列定义

使用 Spring AQMP Java 客户端，我尝试发布到现有的 RabbitMQ 仲裁队列。 如这个 SO 答案所示，我的代码使用“quorum”的 x-queue-type 参数定义目标队列： @

在 Spring Cloud Stream 中全局启用 RabbitMQ 仲裁队列

是否有可能将每个要配置的队列定义为仲裁队列而不是经典队列？ spring.cloud.stream.rabbit.bindings..consumer.quorum.enabled=true 我...

带有RabbitMQ绑定器的Spring云流抛出java.lang.IllegalStateException：消息体太大

我正在使用 Spring Cloud Stream 4.0.4 和 Rabbitmq Binder 4.0.4 来处理 Spring Boot 3.1.3 应用程序中的消息。我也在使用rabbitMQ 3.10.0。问题是，当

RabbitMQ basic.get 和确认

我正在调用： GetResponse 响应 =channel.basicGet("some.queue", false); // 没有自动确认 .... 通道.basicAck(deliveryTag, ...); 但是，当我调用 basicGet 时，队列中的消息会保留...

Spring Cloud Stream Rabbit 使用 ssl 启动时出错

我正在尝试使用Spring cloud Stream从aws（AmazonMQ）连接rabbitmq，并使用ssl连接spring-cloud-stream-binder-rabbit，但是在启动应用程序时出现错误，我不需要

RabbitMQ使用Spring boot，如果队列不存在则应创建

我正在从多个源向RabbitMQ发送数据，如果队列不存在，我想创建它。 公共无效sendMessage（字符串消息，字符串路由键）{ rabbitTemplate.convertAnd...