spring-rabbitmq 相关问题

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

启动SpringBoot应用程序后启动@RabbitListener

我们在Spring引导应用程序中具有RabbitMq实现。这就是我们定义监听器的方式。但是,每当我们启动该应用程序并且队列中有消息时,...的消耗...

回答 2 投票 0

如何使每5秒钟将消息发送到Rabbitmq中的队列?

我是springboot和Rabbitmq的新手。如何使每5秒在Rabbitmq中发送一条消息。我尝试在下面的代码中执行此操作,但不确定。你能帮助我吗?谢谢...示例代码:package com ....

回答 2 投票 0

如何在RabbitMQ Spring框架中使用“声明的对象”动态创建绑定

我的代码获取用户的输入,该输入是路由键的列表,并使用它们将交换机绑定到队列。我使用Declarables为每个路由键生成绑定。问题是,...

回答 1 投票 0

Spring AMQP RabbitListener与2个Rabbit集群连接

我有一个用@RabbitListener注释的侦听器方法,当前将其配置为从1个兔子群集中侦听。现在我有另一个具有相同队列/交换/路由的兔子集群(cluster2)...

回答 1 投票 1

使用rabbitmq的Spring Boot故障转移重试器:无法调用目标方法

我实际上是在尝试使用Rabbit MQ实现故障转移重试器功能。因此,要求是我从队列中获取一条消息并进行处理。如果发生任何问题,则消息...

回答 1 投票 0

自定义RabbitMessageListner引发包装的异常

我从定制库导入org.springframework.amqp.core。*中获得了定制MessageListener。*公共类Subscriber {private SimpleMessageListenerContainer simpleMessageListenerContainer; ...

回答 1 投票 0

Spring AMQP获取现有队列名称和参数

我们在生产中有一个队列,其中通过应用程序设置了消息TTL。现在,我们要更改消息TTL并通过Rabbit CTL附加策略,而不是在应用程序中进行设置。片段:地图

回答 1 投票 0

暂停spring boot rabbit mq消费者的最简单方法是什么?

是否有一种简单的简单方法可以在一段时间后暂停spirng启动AMPQ并恢复?我正在使用Spring Boot Verison 2.6

回答 1 投票 0

当实施死信队列(DLQ)时,会引发通道错误

频道错误;协议方法:#method(reply-code = 406,reply-text = PRECONDITION_FAILED-虚拟主机'ecp-audit'中队列'ecpauditchannel.ecpqueue'的不等价arg'x-dead-letter-exchange':已接收...

回答 1 投票 0

与消费者和Nifi作为调度员的春季整合

我们正在开发一种服务,用于侦听或使用RabbitMQ队列中的消息。消息从Apache Nifi分发到消息队列(例如,队列名称为“ workitems”)。现在,我想...

回答 1 投票 0

RabbitMQ + SpringAMPQ:在SimpleMessageListenerContainer中接收多个队列

我目前正在学习一些有关RabbitMQ + SpringAMQ的知识,我试图使我的SimpleMessageListenerContainer能够读取传递到我的两个队列的消息,但是只有一个正在接收它....

回答 1 投票 0

Spring-AMQP-基于消息头的路由

根据文档:https://docs.spring.io/spring-amqp/docs/2.2.5.RELEASE/reference/html/#async-annotation-driven我们可以基于已转换的消息使用不同的处理程序类类型...

回答 1 投票 0

Spring Cloud Stream-基于带有RabbitMQ活页夹的有效负载类型的调用处理程序

使用Spring AMQP,我可以设置一个包含多个RabbitHandler的RabbitListener,将要调用的RabbitListener取决于有效载荷的类型,如https://docs.spring.io/spring -...]中所述]

回答 1 投票 0

Spring Cloud Stream-手动使用按需数据吗?

使用Spring Data Stream,如何从队列开始读取并按需停止读取?我想要这样的东西:@EnableBinding(Sink.class)公共类SomeConsumer {@StreamListener(...

回答 1 投票 0

带TLS的Spring Boot和Rabbitmq(AMQP 1.0)

我正在寻找一个通过TLS1.2连接到Rabbitmq(或通用AMQP 1.0服务器)的春季启动示例,可能使用一些已经可用的插件。预先非常感谢您的帮助最好...

回答 1 投票 0

Spring反应流-意外关闭

我们正在将Spring Cloud Reactive Streams与RabbitMQ一起使用。一旦将消息从队列中拉出,Spring Reactive Stream似乎就会确认该消息。因此,任何错误都无法处理的异常,...

回答 1 投票 0

兔子MQ-消息顺序优先级消耗

使用Rabbit MQ有办法,我可以确保在使用类型B的消息之前先使用所有类型A的消息。例如:如果我有一个产品和订单消息池,我想确保所有产品...] >

回答 1 投票 0

如何使用RabbitMQ和Spring boot将批量电子邮件发送到电子邮件地址列表?

任何人都可以分享一些消息来源,或者您能告诉我如何使用RabbitMQ和Spring boot发送批量电子邮件吗?在此先感谢

回答 1 投票 0

使用AsyncRabbitTemplate添加非阻塞使用者

我是Rabbitmq的新手,我想建立一个不受阻碍的消费者。我遵循了如何在将AsyncRabbitTemplate与请求/回复模式一起使用时如何构建无阻塞的使用者,并创建了一个...

回答 1 投票 0

RabbitMQ频道空闲问题|如何恢复未确认的AMQP消息| Javaclient使用者

我是Rabbitmq的消费者,并且使用spring-amqp。现在,当我进入admin时,所有连接都显示正在运行,但是其中的所有通道均处于空闲状态(Prefetch:250,Unacked:250)。可以...

回答 1 投票 2

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