spring-amqp 相关问题

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

我正在跟踪rabbitmq，我发现springrabbit在新线程上消费消息。我想知道它在哪里创建新线程

spring rabbitmq spring-amqp spring-rabbit

回答 1 投票 0

无法连接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.

rabbitmq spring-amqp spring-rabbit

回答 6 投票 0

在 TestSuite 中模拟 AMQPTemplate

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

rabbitmq spring-amqp spring-rabbit

回答 1 投票 0

Spring amqp RetryCache 抛出 AmqpRejectAndDontRequeueException 时未清除

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

java rabbitmq spring-amqp spring-rabbit spring-retry

回答 1 投票 0

将 JsonComponent 与 RabbitListener 结合使用

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

spring rabbitmq spring-amqp spring-rabbit jackson-databind

回答 3 投票 0

通道关闭：通道错误：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-amqp spring-rabbit

回答 1 投票 0

顺序运行多个 RabbitMQ 队列

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

rabbitmq spring-amqp spring-rabbit

回答 1 投票 0

基于微服务的应用程序中 RabbitMQ 队列绑定管理的中心位置

我正在开发一个基于微服务的应用程序。它是由约建造的。 30 个微服务，通常其中一些微服务通过 RabbitMQ 相互通信。此类服务有交易所名称、q...

spring-boot rabbitmq message-queue spring-amqp rabbitmq-exchange

回答 1 投票 0

RabbitMq 选择协议时应该注意什么

我尝试深入研究 Java 中的消息传递。我正在研究 RabbitMq 和 AMQP 协议。首先，我重复了 https://spring.io/guides/gs/messaging-rabbitmq/ 中的几个示例以及...

java spring-boot rabbitmq amqp spring-amqp

回答 3 投票 0

带有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。问题是，当

java spring-boot spring-cloud-stream spring-amqp spring-rabbit

回答 1 投票 0

Spring Boot RabbitMQ Pub/Sub 模型，具有运行时队列创建/订阅和容器扩展功能

我有一个带有基本 WebSocketConfigurer 的 Spring Boot 应用程序。在较高的层面上，对于每个已建立的连接，我希望 websocket 会话“订阅”到“通道”

spring spring-boot rabbitmq spring-amqp spring-websocket

回答 1 投票 0

Rabbitmq中的Exchange被意外删除后如何自动恢复

Rabbitmq 中的 Exchange 被意外删除后（从客户端）如何自动恢复。我在我的项目中使用 spring amqp，但我不知道如何激活此功能，我什至无法捕获

spring-boot rabbitmq spring-amqp recovery

回答 1 投票 0

使用多兔子连接时，侦听器会无限重试

我正在使用 spring-multirabbit 配置与 2 个独立的rabbitmq 服务器的连接。春天：多兔MQ：启用：真默认连接：第一个连接连接：首先-

java spring rabbitmq spring-amqp multirabbitmq

回答 1 投票 0

RabbitMQ basic.get 和确认

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

java rabbitmq amqp spring-rabbit spring-amqp

回答 3 投票 0

Spring AMQP/RabbitMQ - java.net.SocketException：连接被对等方重置（写入失败）

我在 Kubernetes 集群中有一个 RabbitMQ 服务器，我使用具有默认设置和 RabbitTemplate 类的 Spring AMQP 连接到该服务器。我在发送方 Spring Boot Microser 中有一个预定的方法...

java spring-boot rabbitmq spring-amqp spring-rabbit

回答 1 投票 0

如何在SpringBoot AMQP中动态生成消息队列并使用PK值绑定键

我想实现一个功能，属于特定群组的用户可以在群组内发布内容，并且该群组的所有成员都会收到通知。为了实现这个目标，我研究了 AMQP...

spring-boot rabbitmq amqp spring-amqp

回答 0 投票 0

如何将消息直接绑定到我的对象类

我收到如下消息，其中包含 2 个 HashMap（inputMap 和 outputMap）。使用 ObjectMapper 的方法是否正确？示例消息：在 RabbitMQ 中： {"ORCH_KEY":{"inputMap":{},"

java spring-amqp spring-rabbit

回答 2 投票 0

如何在 Spring AMQP 中使用 kotlinx 序列化？

spring AMQP 似乎内置了 MessageConverter 对 Jackson2JsonMessageConverter 类的 Jackson 支持，但是是否有 kotlinx 序列化库的等效项，或者是

jackson spring-amqp kotlinx.serialization

回答 1 投票 0

Rabbit Mq 在第一条消息后不使用消息

在队列中发布消息后，在监听端收到两次相同的消息。在接收到第一条消息后，监听器停止进一步消费消息。在我重新启动侦听器应用程序后...

java spring rabbitmq amqp spring-amqp

回答 1 投票 0

如何使用 Spring AMQP 检测到 RabbitMQ 生产者未能将消息发送到 Java 中的适当队列？

我正在尝试使用 Spring AMQP 库验证发送的消息是否已成功放入队列中。当我向队列发送消息时，我发现这些方法似乎没有出错......

java spring rabbitmq spring-amqp

回答 1 投票 0

spring-amqp 相关问题

最新问题