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

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

Spring AMPQ兔模板发布确认
Spring AMPQ rabbit-template publish confirmation

我试图在RabbitTemplate的帮助下使用RabbitMq(我正在使用Spring启动应用程序)。我能够做通信部分,它可以正常工作,但我有一个问题。 问题:怎么......

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

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

SimpleMessageListenerContainer批量消息处理
SimpleMessageListenerContainer bulk message processing

我有一个传入数据流,作为单独的消息发送到RabbitMQ。 我想将这些发送到需要一批消息的服务。 当我......我需要将请求发送给服务

SpringAMQP延迟
SpringAMQP delay

我无法确定在SpringAMQP中延迟消息级别的方法。 如果服务不可用,或者如果它抛出一些异常我将所有请求存储到RabbitMQ中,我调用Web服务...

春兔和春交易
spring rabbit and spring transactions

我有一个像春天兔子一样的消费者:@Override public void onMessage(Message amqpMessage,Channel channel)抛出异常{// ..有些代码在这里 - 我希望它在春天...

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

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

在Flume Lifecycle中使用Spring AMQP onMessage()方法
Using Spring AMQP onMessage() method within Flume Lifecycle

我需要听一下我开发的Flume Custom Source中的Rabbit Queue。这个要求在Flume中看起来很尴尬。但这就是它的需要。 因为我正在使用Spring AMQP来听...

在spring amqp SimpleMessageListenerContainer中处理异常的最佳策略是什么
What is the best strategy to handle exception in spring amqp SimpleMessageListenerContainer

我有两个困惑。 1.如果从消息侦听器抛出RuntimeException,SimpleMessageListenrContainer会停止吗? 2.如果SimpleMessageListenerContainer没有停止,那么关于auto的行为是什么...

在Spring CachingConnectionFactory中设置connectionTimeouts和socketTimeouts
Set connectionTimeouts and socketTimeouts in Spring CachingConnectionFactory

我正在使用Spring AMQP库。如何在CachingConnectionFactory中配置connectionTimeouts和socketTimeouts.I假设它必须在内部使用http://www.rabbitmq.com/javadoc/com/rabbitmq / ...

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

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

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

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

@RabbitListener用于多个类中的相同队列
@RabbitListener for the same queue in multiple classes

我想知道Spring AMQP是否有可能从多个类中的同一队列接收消息,具体取决于有效负载类型。 我知道在课堂上使用@RabbitListener注释...

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

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

Reactive Spring Cloud Stream从队列中读取所有数据,但非响应性逐个读取消息
Reactive Spring Cloud Stream reads all data from queue, but non-reactive reads messages one by one

我注意到Spring Cloud Stream的反应性和非反应性行为的差异。 当我使用非反应式方法时,将逐个读取消息。 这是为流监听器剪切的代码:@ ...

如何将RabbitMQ中的JSON消息转换为Java对象?
How do I convert a JSON message from RabbitMQ to a Java object?

我有两个独立的Java应用程序,我需要通过RabbitMQ使用spring-rabbit发送消息。 在作为生产者的应用程序中,我使用JsonMessageConverter作为我的消息转换器...

java.lang.ClassCastException:JedisConnectionFactory无法强制转换为ConnectionFactory
java.lang.ClassCastException: JedisConnectionFactory cannot be cast to ConnectionFactory

我不确定为什么方法“connectionFactory”返回JedisConnecionFactory的实例,如果它不是org.springframework.amqp.rabbit.connection.ConnectionFactory? 以下例外......

在rabbitmq中预取计数与无ack之间有什么区别
What is the difference between prefetch count vs no ack in rabbitmq

我需要知道在rabbitmq中prefetch count与no ack之间的区别是什么? 以下语句之间有什么区别: - 如果我设置预取计数,则表示10确实为10个消费者...

RabbitMQ basic.get和确认
RabbitMQ basic.get and acknowledgement

我正在调用:GetResponse response = channel.basicGet(“some.queue”,false); //没有auto-ack .... channel.basicAck(deliveryTag,...); 但是,当我调用basicGet时,队列中的消息仍然存在...

将未确认的消息(异常时)放入RabbitMQ中的其他队列
Put unacknowledged message(on exception) to a different queue in RabbitMQ

在处理来自RabbitMQ的消息时出现异常时,我只想取消确认并将特定消息放回到差异队列中,或者重新排队到同一队列或完全丢弃...

SPRINGAMQP或RabbitMq Java API
SPRINGAMQP or RabbitMq Java API

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

@RabbitListener可以按条件申请
Can @RabbitListener apply by condition

我希望在存在属性时创建RabbitListener,但@ConditionOnProperty不能与@RabbitListener结合使用。 现在我有一个解决方法如下。 它有没有更好的方法? @豆 @...

Spring AMPQ - 创建具有到期的队列Bean
Spring AMPQ - Create Queue Bean with expiration

我应该如何创建一个RabbitMQ队列作为基于注释的Bean,并设置消息过期? 以下代码似乎不起作用。 @Bean()public Queue theQueue(){Map <String,Object&...

春天REST消息总线通信
spring REST message bus communication

我正在寻找可以帮助我将Spring REST Web服务与消息总线(RabbitMQ)集成的spring模块。 REST Web服务充当来自客户端的AMQP消息的使用者。 每当......

spring-amqp具有不同routingKey的多个队列
spring-amqp Multiple queues with different routingKey

我最近开始学习Spring和spring-amqp所以这个问题可能看起来很基本所以请原谅我。 我有多个队列在不同的主机上,并有不同的...

使用RabbitMQ自定义目标
Custom destination with RabbitMQ

我正在尝试将RabbitMQ用作我项目中的代理,并且我想在客户端打开套接字时分配目标队列。 像这样:http://i.imgur.com/ldB2M0m.png我......

基于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 Amqp在springframework RetryCallback类中有NoClassDefFoundError
Spring Amqp has NoClassDefFoundError in springframework RetryCallback class

我一直在研究分布式Web项目,我想在其中使用带有RabbitMq的Spring amqp。 我在我的项目中使用springFramework版本4.1.6。 为此,我添加了以下内容......

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连接似乎保持...

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

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

Rabbitmq连接在localhost上突然关闭
Rabbitmq connection close abruptly on localhost

我们在localhost dev /测试场景中对rabbitmq有突然的连接关闭问题。 在我们的开发环境中,我们在每个开发人员的Windows 7机器上安装了rabbitmq,我们连接到...

我怎样才能得到correlationId?
how can i get correlationId?

在我的项目(spring-rabbit ..)上,在模板上设置固定的ReplyTo队列,我对RPC使用convertSendAndReceive方法。 我明白mekes correlationId会自动生成。 我可以在......之前设置correlationId吗?

RabbitMQ固定回复和消费者配置
RabbitMQ fixed reply and consumer configutation

我的目标是实现以下目标:php代码向队列发送请求 - java代码从代码中读取 - java代码发送回复到固定回复队列 - php代码读取回复。 我已经设置了以下内容......

Spring AMQP模板
Spring AMQP Template

请帮帮我。 是来自RabbitMQ(AMQP协议的实现)线程安全的AmqpTemplate类的实例。 可以从多个线程访问吗? 谢谢

RabbitMQ教程代码不起作用
RabbitMQ tutorials code not working

我正在学习RabbitMQ。 我开始在他们的网站上使用基本的rabbitmq教程,遗憾的是由于以下错误我无法编译它们:ConnectionFactory ...

auto-startup =“false”导致退出进程
auto-startup="false" causing to exit the process

我们一直在使用auto-startup =“true”,一切正常。 我们一直在使用Controlbus来启动/停止适配器。 我们必须更改auto-startup =“false”然后使用Control启动适配器...

带有Rabbit Binder的Spring Cloud Stream - 源/接收器队列名称不匹配
Spring Cloud Stream with Rabbit Binder - source/sink queue names don't match

最近,我开始使用Spring Cloud Stream和RabbitMQ binder。 如果我在两个服务想要传递消息时正确理解了所有内容,那么应该配置发送消息的源...

使用Spring AMQP和RabbitMQ HA进行故障转移
Failover with Spring AMQP and RabbitMQ HA

有多篇文章建议在RabbitMQ集群之前使用负载均衡器。 但是,还有多个引用,Spring AMQP正在使用一些故障转移......

处理Publisher在Spring AMQP-RabbitMQ中确认超时
Handling Publisher Confirm timeout in Spring AMQP-RabbitMQ

我正在测试AMQP的Spring RabbitMQ实现,我想使用发布者确认。 我在文档和代码中遗漏的是我应该如何处理未经证实的...

使用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 =“...

Spring AMQP Integration - Consumer Manual Acknowledgement
Spring AMQP Integration - Consumer Manual Acknowledgement

我正在使用Spring-Integration支持测试Spring-AMQP,我正在进行配置和测试:<rabbit:connection-factory id =“connectionFactory”/> <rabbit:queue name =“durableQ”/> <...

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

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

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

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

在多线程环境中,我应该在哪里将线程相关数据存储在接收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 ...