使用RabbitMQ进行基于AMQP的消息传递的Spring组件。
Spring-Rabbitmq侦听器需要在数据库更改期间暂停和恢复
嘿,要求是在更改后端表期间暂停Rabbitmq侦听器处理消息。此更改仅限于我的应用程序,因此不想降低...
Spring Cloud Stream具有自动重新连接Rabbitmq
失去连接后,我需要重新连接Rabbitmq。我想知道春天的云流是否有这个。感谢。
我正在使用RabbitMQ / Spring / Spring AMQP构建应用程序,并且在处理排队方式时遇到了麻烦。本质上,我有一个队列,每个消费者都在听,每个队列都在听...
我想在这里了解一些事情。我的要求是我想在db中存储记录并希望将消息发送到队列然后让我们说同样的方法如果它抛出一些我不想要的异常...
如何在消息(@RabbitListener)中创建有状态服务(几个@Autowire),如果新消息,状态应该是干净的。在@Service的RabbitQM(Spring AMQP)之前,我使用了@Scope(value = ...
我读了很多文档/ stackoverflow,但是当发生异常以将消息移动到死信队列时,我仍有问题。我正在使用spring-boot这是我的配置:@Autowired private ...
RabbitMQ通过Spring的RabbitAdmin调整HA队列
我想知道:有没有办法只使用Java Spring代码设置RabbitMQ镜像(HA队列)。 AFAIK有一个特殊的类RabbitAdmin用于这样的配置问题,但不能......
独占消费者失败时要处理的AmqpEvent或AmqpException
我有两个相同应用程序的实例,在不同的虚拟机中运行。我想为其中一个的使用者授予对队列的独占访问权限,同时使本地缓存无效...
Spring MongoDB无法实例化Map类型:org.springframework.messaging.MessageHeaders
我正在使用带有RabbitMQ和MongoDB的Spring启动。我有一个死信队列设置,它将我的DeadLetterMessage保存在Mongo中。当我想从数据库中检索这些消息以重新排队时......
org.springframework.amqp.UncategorizedAmqpException
获得以下异常的原因是:org.springframework.amqp.UncategorizedAmqpException org.springframework.amqp.UncategorizedAmqpException:java.lang.IllegalStateException:无效...
防止spring-rabbit中的@RabbitListener在集成测试期间尝试连接到服务器
我想为使用rabbitMq的服务运行一些验收测试但是我想忽略所有需要服务间通信(amqp)的服务。然而问题是Spring试图......
我正在使用带有Spring的RabbitMQ构建一个应用程序:到目前为止一直很好。定义单元测试我使用JUnit定位外部服务器。我想知道的是,如果有办法嘲笑......
如何在春季启动测试中模拟spring amqp / rabbit
如何模拟spring rabbitmq / amqp,以便在尝试自动创建交换/队列时在Spring Boot Test期间不会失败?鉴于我有一个简单的RabbitListener将导致队列和......
我正在使用带有spring-rabbitmq的spring-boot。我的连接工厂在application.properties中配置,看起来很不错。我的目标是:在开始检查期间是否存在特定名称的队列,...
我是RabbitMQ的新手。我在Spring配置中使用以下监听器:@RabbitListener(queues =“$ {rabbitmq.queue.a}”)@ SendTo(“$ {rabbitmq.queue.b}”)public ResponseMessage receive(...
我有一个场景,我需要在特定事件中从交换机中分离一个rabbitmq消费者,以便它停止消耗队列中的消息,然后将相同的消费者重新连接到...
嗨,我正在开发Spring-boot-RabbitMQ版本1.6。我在开发应用程序时几乎没有查询。阅读文档并浏览其他堆栈溢出问题,但我无法清楚地了解一些事情(...
我有一个带有消息的兔子队列。我也有一个失败的倾听者。队列配置了死信交换(以及死信队列)。我想要的是看到......
绑定交换以通过Spring cloud stream与rabbitmq binder交换
我正在寻找一种通过Spring云流将RabbitMQ交换绑定到另一个的方法。我知道我可以通过设置producer.requiredGroups属性将队列绑定到交换:spring.cloud ....