使用Spring ampq在rabbitmq中重新排列消息
requeue the message in rabbitmq using Spring ampq

我是rabbitmq的新手,我正在尝试以下场景 - >生产者发送消息 - >消费者收到消息 - 如果逻辑失败,则执行我自己的逻辑 - 重新排队 - >重新排队...

春季启动 - RabbitMQ消费者继续打印“检索消费者的交付”
Spring boot- RabbitMQ consumer keep on printing "Retrieving delivery for Consumer"

嗨,我使用Spring boot 1.3.5和启动RabbitMQ。 在这个项目中,我有一个RabbitMQ消费者,它消耗来自特定队列的消息。但是在运行应用程序时,它保持...

如何将错误消息移动到rabbitmq死信队列
How to move error message to rabbitmq dead letter queue

我读了很多文档/ stackoverflow,但是当发生异常以将消息移动到死信队列时,我仍有问题。 我正在使用spring-boot这是我的配置:@Autowired private ...

Spring Cloud Stream Rabbit Binder路由密钥总是'#'
Spring Cloud Stream Rabbit Binder Routing Key always '#'

版本:Spring Boot:1.4.2.RELEASE Spring Cloud Deps:Brixton.SR7这是我的处理器应用程序的application.properties。 logging.level。= DEBUG server.port = 0 logging.file = traveler-events-processor ....

无法使用SprintBoot在RabbitMQ中解密消息
Not able to nack messages in RabbitMQ using SprintBoot

我有以下的Consumer类,它侦听队列中的传入消息,然后确认并确认它们。 ack部分工作正常,但nack无法正常工作。 所有的消息都得到......

Spring Boot RabbitMQ的任何单元和集成测试工具或框架?
Any Unit & Integration Testing tool or Framework for Spring Boot RabbitMQ?

我使用Spring boot和RabbitMQ为多个生产者和消费者开发了一个应用程序。 应用程序工作正常没有任何问题,但我仍然想做单元测试和...

RabbitMQ持久队列通过STOMP丢失消息
RabbitMQ durable queue losing messages over STOMP

我有一个网页连接到一个兔子mq代理使用javascript / websockets,由tomcat中部署的spring应用程序公开。 消息由外部应用程序每秒产生1次,并且是......

在SpringBoot中重试与RabbitMQ和MongoDB的连接
Retry Connection to RabbitMQ and MongoDB in SpringBoot

我正在使用spring并且想要重试获取与RabbitMQ和MongoDB的连接,如果它失败了。 我知道这对sql数据库有用:https://github.com/spring-projects/spring-boot/issues / ...

Spring - Rabbit模板 - 批量操作
Spring - Rabbit template - Bulk operation

任何人都知道是否可以使用Rabbit模板将消息集合发送到队列? 显然我可以一次发送一个,但我想在一次批量操作中完成它(获得...

Rabbit监听器注释从yaml获取队列名称
Rabbit listener annotation get queue name from yaml

我目前将我的兔子监听器注释设置为:@RabbitListener(queues =“my-queue”)是否无法从我的yaml文件中提取队列名称。 我想这样做的原因是我......

SPRINGAMQP或RabbitMq Java API
SPRINGAMQP or RabbitMq Java API

我是rabbitMq和Spring AMQP的新手。 我正在从头开始构建一个新项目。 这里有一个组件我们使用rabbit-Mq作为消息代理。 在这个项目中,主要是所有......

Spring AMQP ListenerContainer生命周期管理
Spring AMQP ListenerContainer lifecycle management

我们使用Spring AMQP在基于Spring的Web应用程序中连接到RabbitMQ。 当我们在应用程序上下文中将我们的侦听器容器声明为bean(使用rabbit:listener-container)时,它们......

基于Spring Boot的应用程序中的死信路由
Dead Letter routing in Spring Boot based application

我已经阅读了关于该主题的多个答案,似乎我的配置应该正常工作,但由于某种原因它没有。 这是配置:@Bean Queue intakeQueue(String name){return ...

与java-client / spring-rabbit的rabbitmq-consistent-hash-exchange
rabbitmq-consistent-hash-exchange with java-client / spring-rabbit

我想使用java客户端的rabbitmq-consistent-hash-exchange的功能,或者最好使用spring abstract spring-amqp。 不幸的是我没有找到一个例子......

Spring-rabbitmq - 即使在连接不足的情况下也可以启动spring-boot服务器
Spring-rabbitmq - start spring-boot server even in case of lack of connection

我正在使用RabbitMQ的春季启动。 一切正常 - 处理消息有效,失去连接后会自动尝试重新连接。 但是,我只有一个问题:当......

spring-amqp使用非线程安全的侦听器实现零消费者利用率
spring-amqp zero consumer utilization with non thread-safe listener

我们在生产中遇到了一个问题,即消费者利用率为零,队列不断增长,性能下降。 每个消费者都是一个包含......的容器。

处理Spring-Boot-RabbitMQ中的连接
Handling Connections in Spring-Boot-RabbitMQ

嗨,我正在开发Spring-boot-RabbitMQ版本1.6。我在开发应用程序时几乎没有查询。 阅读文档并浏览其他堆栈溢出问题,但我无法清楚地了解一些事情(...

如何在Spring Rabbit中干净地关闭RabbitTemplate?
How can I cleanly shut down a RabbitTemplate in Spring Rabbit?

我编写了一个脚本,它使用Spring Rabbit在Rabbit队列中使用RabbitTemplate.convertAndSend放置大量消息,然后退出。 然而,Rabbit连接似乎保持...

无法启用/监控spring-cloud-bus的端点以进行推送通知
Cannot enable /monitor endpoint for spring-cloud-bus for push notifications

我已经配置了spring cloud config来从git repository读取属性。如果配置发生了变化,那么当前的实现,如果在我的客户端上发布到/ refresh我能够......

通过创建元注释重用注释
Reusing annotations by creating meta annotations

我只是想知道我们是否可以创建一个元注释并在任何地方重复使用它。 例如,我有一个这样的注释:@QueueBinding(value = @Queue,exchange = @Exchange(value =“...

停止后,SimpleMessageListenerContainer无法恢复
SimpleMessageListenerContainer is not recover after stoping it

当某个事件到来时,我使用container.stop()停止我的rabbitmq列表器; 完成所需的工作后,我用container.start()重新启动它,但是当一个新的事件到来时,我得到了以下......

如何使用spring rabbitmq配置不同队列中的超时,重试或最大尝试次数
how configure timeouts, retries or max-attempts in differents queues with spring rabbitmq

是否可以为每个队列进行这些设置? 我有重要的队列,所以我需要更多的重试,但有不太重要的队列,我不想配置重试,...

Spring AMQP - 发件人和接收邮件
Spring AMQP - Sender and Receiving Messages

我在接收RabbitMQ的消息时遇到了问题。 我发送的消息如下HashMap <Object,Object> senderMap = new HashMap <>(); senderMap.put(“STATUS”,“...

RabbitMQ请求/响应“RabbitTemplate未配置为侦听器”
RabbitMQ request/response "RabbitTemplate is not configured as listener"

我正在使用Spring-AMQP rabbitmq实现测试请求/响应模式,我无法使其工作......我已经配置了以下工件:带问候队列的test_exchange。 路由键= ...

RabbitMqListener没有正确地侦听相同的路由键
RabbitMqListener not listening properly for same routingkeys

我有一个要求,我必须听同样的交换,相同的队列,但不同的路线。 以下是来自差异路由的侦听消息的代码@Component public class EmailMessageHandler {...

使用amqp在spring-boot中使用基于注释的侦听器NACK消息的正确异常类型是什么?
What's the correct exception type to NACK a message using annotation based listener in spring-boot with amqp?

我正在使用带有spring-amqp和基于注释的侦听器的spring boot来使用来自rabbitmq代理的消息。 我有一个spring组件,它包含这样的方法:@RabbitListener(queues =“...

获得运行弹簧启动涡轮流的预期
Getting expection on running spring boot turbine stream

@EnableHystrixDashboard @EnableTurbineStream public class MonitoringApplication {} application.yml eureka:instance:prefer-ip-address:true leaseRenewalIntervalInSeconds:10 ...

在有限的重新尝试之后从兔子MQ中删除消息
Remove message from rabbit MQ after limited attempts of requeing

我把文件中的记录放入兔子mq,从队列中读取记录并调用服务。对于被拒绝的记录,我发送一个否定的确认并用channel.basicNack方法重新排队。但是...

Spring AMQP相比RabbitMQ Java客户端有什么优势吗?
Does Spring AMQP has any advantages over the RabbitMQ Java client?

我正在使用RabbitMQ集群进行工作队列。 我想知道在使用Spring AMQP时是否有任何功能可以简化与RabbitMQ集群的交互? 或者最好使用官方Java ...

如何在Spring RabbitMQ项目中使用多个vhost?
How to use multiple vhosts in a Spring RabbitMQ project?

我有以下两个配置类:@Configuration @EnableRabbit @Import({LocalRabbitConfigA.class,CloudRabbitConfigA.class})公共类RabbitConfigA {@Autowired @Qualifier(“...

RabbitMQ生产者不会终止
RabbitMQ producer doesn't terminates

我有一个生产者,它将数据发送到RabbitMQ(版本3.6.1)。 以前我使用的是rabbitmq-client jar,应用程序运行正常。 现在我切换到spring-amqp 1.2.0,这也是......

在多线程环境中,我应该在哪里将线程相关数据存储在接收rabbitListener组件中?
Where should i store thread dependent data within a receiving rabbitListener component in a multithreaded environment?

我在多线程环境中使用spring amqp的基于注释的方法(我有多个consumer =>多个兔子监听器容器)。 @RabbitListener(queues =“tasks”)public void ...

增加春兔的心跳值
Increase heartbeat value in spring rabbit

我的设置遇到了一些问题,我正在尝试增加心跳间隔以测试可能的修复。 我正在使用Spring boot 1.3.2.RELEASE Spring rabbit 1.5.3.RELEASE和...

如果使用rabbitmq镜像队列进行HA,应该定义应答队列是否持久?
if using rabbitmq mirror queue for HA, should define reply queue durable?

如果使用带有RPC模式的HA的Rabbitmq镜像队列,应该定义应答队列持久吗?同时,任何特殊的配置要做什么?

@RabbitListener的重试配置以编程方式指定死信队列
Retry Configuration for @RabbitListener programatically specify dead-letter queue

我一直试图找到一种方法来为所有@ RabbitListener设置重试机制。 我已经尝试过这些属性:listener:auto-startup:true concurrency:1 max-concurrency:1 retry:...

如何一起使用Rabbit Connection Cache Mode和Autodeclare Features?
How to use Rabbit Connection Cache Mode and Autodeclare Features Together?

Spring AMQP Reference指出:从版本1.3开始,CachingConnectionFactory可以配置为缓存连接以及通道。 在这种情况下,每次调用createConnection()......

使用RabbitMQ基于密钥(例如id)确定并发性
Determine concurrency based on a key (such as an id) with RabbitMQ

我们正在使用RabbitMQ和Spring的侦听器容器构建一个Web应用程序来生成并发,如下所示:<rabbit:listener-container connection-factory =“connectionFactory”concurrency =“...

在Spring XD中使用RabbitMQ作为消息总线的耗尽消息
Exhausted messages in Spring XD with RabbitMQ as the message bus

我有一个Spring XD 1.2.0安装,一个服务器和几个使用RabbitMQ作为消息总线的容器,我在日志中看到了很多WARN消息,例如:2017-02-05T22:51:03+ .. 。

在rabbitmq autoconfig connectionfactory bean上设置heartbeat属性
set heartbeat property on rabbitmq autoconfig connectionfactory bean

我应该如何在rabbitmq spring中的CachingConnectionFactory bean上设置heartbeat属性? 这是在云代工环境中。 所以应用程序将通过清单使用服务绑定...

Spring Integration RabbitMQ + Consume来自amq.rabbitmq.event主题交换的内部事件
Spring Integration RabbitMQ + Consume Internal events from amq.rabbitmq.event topic exchange

我想使用发布到amq.rabbitmq.event的内部事件,例如client.connected,client.disconnected。 下面是我的Spring配置:<?xml version =“1.0”encoding =“UTF -...

SpringBoot禁用兔子健康检查的rabbitTemplate重试策略
SpringBoot Disable rabbitTemplate retry policy for rabbit health check

我的SpringBoot配置包含针对rabbitTemplate重试的非常强的重试策略spring:rabbitmq:template:retry:enabled:true initial-interval:500 max -...

Spring Boot - RabbitMQ - 处理经纪人失败的场景
Spring Boot - RabbitMQ - Handle Scenario where broker is down

我们在项目中使用rabbitmq进行消息传递。 这主要用于审计日志记录。 我们试图检查我们的应用程序如何响应某些故障情况。 例如,如果RabbitMQ关闭,...

spring boot rabbitMQ DLE不接受任何消息
spring boot rabbitMQ DLE not accepting any messages

我正在开发spring-boot rabbitMQ。 我正在创建一个死信队列,我可以在RabbitMQ管理员中看到“D,DLE”,但没有DLK可能是我缺少设置“x-dead-letter-routing-key”,...

是否可以使用Java应用程序将JSON对象传递给RabbitMQ队列?
Is it possible to pass JSON object to the RabbitMQ queue using java application?

我想将JSON对象传递给RabbitMQ队列。 在下面的代码中,我使用obj.toJSONString()。getBytes()将Json对象转换为string,是否可以在队列中传递JSON对象...

RabbitMQ和分布式数据库事务中的交付保证
RabbitMQ and Delivery Guarantees in Distributed Database Transaction

我试图了解在分布式数据库事务的上下文中处理RabbitMQ交付的正确模式是什么。 为了简单起见,我将用伪代码说明我的想法,......

spring-amqp清理侦听器容器关闭时的资源
spring-amqp clean up resources on listener container shutdown

我有多个消息容器,每个容器都有一个监听器。 每个监听器都不是线程安全的声明@Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE)不是无状态的。 它有内部......

春兔消息消耗,有效负载格式错误
Spring rabbit message consumption, payload wrong format

我正在使用rabbitmq中的队列消息,比如@RabbitListener(queues =“#{'$ {rabbitmq.queues}'。split(',')}”)public void processOrder(@Payload String data,@ Header(AmqpHeaders) ....

一个消费者的双重连接
Double connections for one consumer

我是RabbitMQ的新用户,我真的很喜欢它,但我有一个问题(它不会引发任何错误,除了我的想法,它不会影响任何事情......)。 每次我运行一个消费者,它会创建2 ...