spring-amqp 相关问题

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

在 AMQP Spring XML 中解除队列与交换的绑定?

有没有办法在 Spring XML 文件中以声明方式解除队列与交换的绑定? 我根据 ChatGPT 的结果尝试了此操作,但“unbind-queue”元素不存在,

回答 0 投票 0

如何在 Spring Boot 中设置 amqp RabbitMQ 消费者标签?

在问题How to set the consumer-tag value in spring-amqp 中被问到如何在使用 Spring Amqp 时更改消费者标签,答案建议提供

回答 3 投票 0

从 XML 到 Java 的 Spring AMQP 应用程序配置

我正在努力将 RabbitMQ 应用程序配置从 XML 重写为 Java。可悲的是,一旦执行代码,就会出现非常普遍的错误: org.springframework.amqp.rabbit.listener.exception.

回答 1 投票 0

Spring-amqp-QueueBuilder 应该保留对队列的引用而不是字符串名称

我有 2 个匿名队列。他们都设置了 ___Declarables extends AbstractAmqpDeclarables 在启动时实例化为@Bean。 但是在启动时 - rabbitMQ 还没有给出 ...

回答 0 投票 0

如何为Spring Integration中的Rabbit MQ消息监听器执行严格的排序?

我有一个Spring集成项目,我从RabbitMQ队列中发送和接收消息。系统发布消息的顺序是确定的,但之后接收消息的顺序......。

回答 1 投票 0

CachingConnectionFactory确认类型简单与相关。

CachingConnectionFactory确认类型简单与相关的区别是什么。

回答 1 投票 0

DirectMessageListenerContainer可以和BatchMessageListener一起使用。

在当前版本org.springframework.amqp: 2.2.2 BatchMessageListener中包含。@Override default void onMessage(Message message) { throw new UnsupportedOperationException("不应该被...容器调用"); @Override default void onMessage(Message message) { throw new UnsupportedOperationException("不应该被...

回答 1 投票 0

如何在spring-rabbitmq 1.x中获取consumerTag?

spring-rabbitmq的配置是这样的 org.springframework.amqp 兔宝宝 1.1.3....

回答 1 投票 0

Spring AMQP RabbitListener调整自动重连配置。

我试图更好地理解RabbitListener的行为,当broker宕机时& 当它被恢复时。我已在本地主机:6672 的 docker 容器中设置了一个 rabbit,并创建了一个 ...

回答 1 投票 0

Spring AmqpAdmin在vHost中创建Exchange & 队列。

类似于RabbitMQ Spring AMQP发送消息到任意vhost交换的问题,但我试图让AmqpAdmin在特定的vHost下创建交换,我试着做了一些事情... ...

回答 1 投票 0

setConfirmCallback vs setReturnCallback

为什么setReturnCallback执行在setConfirmCallback之前,理想情况下setConfirmCallback回调方法应该执行在返回回调之前。

回答 1 投票 0

RabbitMQ SSL 与 spring-amqp 1.4.3 的连接。

我正试图通过 SSL 连接到 RabbitMQ。我遵循了此处链接的 RabbitMQ SSL 文档 https:/www.rabbitmq.comssl.html 根据 RabbitMQ SSL 文档,使用 SSLv3 和......进行连接。

回答 2 投票 2

Spring AMQP多线程调用消息监听器

我有一个DirectRabbitListenerContainer(通过DirectRabbitListenerContainerFactory创建),其中我通过MessageListenerAdapter设置了一个MessageListener。我所遇到的问题是...

回答 1 投票 0

如何从外部启动spring RabbitMQ Listerner

我有一个要求,我的兔子mq使用者不应在bootRun上使用该消息。但是使用者必须在完成其他一些依赖项的部署后开始使用消息...

回答 1 投票 0

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

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

回答 1 投票 0

在Spring Boot上为Spring AMQP和RabbitMQ动态设置主机

我有问题,我不知道如何动态设置主机并在其他主机上执行RPC操作。这是我在多个服务器和网络上运行多个RabbitMQ的情况(...

回答 1 投票 0

如何在Spring AMQP中使用注释将队列/消息的持久性设置为false?

我编写了示例spring amqp生产者,该生产者运行在RabbitMQ服务器上,该服务器使用Spring AMQP在MessageListener上发送消息并使用这些消息。在这里,我想设置队列和消息...

回答 1 投票 1

在RabbitListenerErrorHandler中发送回复,但仍发送NACK消息?

我有一条使用Spring Boot和RabbitMQ处理任务的服务管道。每个服务都使用队列中的消息,进行一些工作,然后重新发送,作为要由...处理的消息,以进行处理...

回答 1 投票 0

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

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

回答 1 投票 0

从springboot 2.0.2迁移到2.2.2时的JSON退化问题

我将项目从Spring Boot 2.0.2迁移到2.2.2,也从Java 8迁移到Java11。在此期间,刷新Spring总线时出现json的反序列化错误。项目开始...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.