spring-amqp 相关问题

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

无相关标题回复

[我在使用rabbitmq时遇到问题，在最新版本的springboot中使用rabbitmq，有一个convertSendAndReceive（..）方法，具体用法如下Object object = RabbitTemplate ....

java spring-amqp

回答 1 投票 0

带有两个ConnectionFactory的Spring AMQP

我有一个带有两个ConnectionFactory的应用程序（不同的代理）。它们使用java类进行配置：@Bean public ConnectionFactory ... @ Bean public Queue ......

spring spring-amqp

回答 1 投票 1

如何将bean声明为顶层，这是SpringAMQP的要求

我曾尝试在Spring中创建bean，在Spring核心的早期版本中将bean定义为beans.xml。 SpringAMQP要求将队列，主题交换和绑定声明为顶级...

java spring spring-boot spring-mvc spring-amqp

回答 1 投票 0

Spring AMQP RabbitListener与2个Rabbit集群连接

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

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 1

如何从RabbitMQ死信队列中逐个使用消息

该要求就像通过公开REST服务API（Spring Boot）来处理死信队列中的消息。这样，一旦调用REST服务，就会从DL队列中消耗一条消息...

spring-boot rabbitmq spring-amqp

回答 2 投票 2

RabbitMq侦听器引发的问题处理异常

我在我的项目中有此侦听器：@Service @RequiredArgsConstructor @ Slf4j公共类ConsumerService {@RabbitListener（queues =“ $ {queue.treatment.request}”））public void ...

java spring-boot rabbitmq spring-amqp

回答 1 投票 0

自定义RabbitMessageListner引发包装的异常

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

spring-amqp spring-rabbitmq

回答 1 投票 0

Spring AMQP-发布者确认不关闭未使用的频道

发布和获取ack / nacks的工作正常。我在这里的担心是，它不会关闭未使用的额外通道。另一方面，将发布者确认设置为false时，未使用的...

java spring-boot amqp spring-amqp rmq

回答 1 投票 0

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

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

spring spring-amqp spring-rabbitmq spring-rabbit

回答 1 投票 0

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

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

java spring-amqp spring-rabbitmq messagebroker

回答 1 投票 0

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

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

spring-boot spring-amqp spring-rabbitmq spring-rabbit

回答 1 投票 0

Spring Cloud Stream-@StremListener条件

根据文档：https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.3.RELEASE/reference/html/spring-cloud-stream.html#_using_streamlistener_for_content_based_routing我可以。 ..

spring-boot spring-cloud spring-cloud-stream spring-amqp

回答 1 投票 0

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

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

spring-boot spring-cloud-stream spring-amqp spring-rabbitmq

回答 1 投票 0

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

使用Spring Data Stream，如何从队列开始读取并按需停止读取？我想要这样的东西：@EnableBinding（Sink.class）公共类SomeConsumer {@StreamListener（...

spring-boot spring-integration spring-cloud-stream spring-amqp spring-rabbitmq

回答 1 投票 0

春季云环境中的分布式Rabbitmq

[我正在尝试使用以下组件1或更多云配置服务器1或更多Eureka服务器1 ...基于当前的春季云发行版（主要是指Netflix OSS）设置分布式系统，]