spring-rabbitmq 相关问题

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

tomcat服务器依赖于rabbitmq服务器

我正在将RabbitMQ服务器集成到我定制的spring-Amqp项目中,作为基于spring mvc Design的。我在xml中配置了所有配置。当RabbitMq服务器关闭时,我正在尝试...

回答 1 投票 0

如何为RabbitMQ和Spring动态注册队列及其独占的使用者/监听器?

我有以下问题需要解决:我正在尝试使用RabbitMQ消息传递实现一个简单的延迟重试机制。我有一个基础设施,让我延迟交付......

回答 1 投票 0

围绕使用@RabbitHandler注释的方法的方面

我想要的是围绕用@RabbitHandler注释的所有方法的一个方面,以便AssertionErrors不会杀死处理程序线程。我只想将它们包装在RuntimeExceptions中并重新抛出....

回答 2 投票 1

使用spring-rabbit-test for Junit

我正在尝试为rabbitMq监听器编写测试用例。我尝试使用spring-rabbit-test并在运行测试时遇到以下错误:启动ApplicationContext时出错。要显示条件......

回答 1 投票 2

如何在SimpleRabbitListenerContainerFactory中使用RetryInterceptorBuilder重试时启用异常日志记录?

我有一个SimpleRabbitListenerContainerFactory定义如下:@Bean public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory){...

回答 1 投票 1

rabbitmq - 不会获取队列中的所有消息

我正在尝试使用本教程(https://spring.io/guides/gs/messaging-rabbitmq/)与rabbitmq一起玩,我不知道为什么我不能立即收到所有消息。代码片段:亚军....

回答 1 投票 0

Spring AMQP使用noLocal使用者发送和接收临时队列

使用临时队列发送和接收时,会创建一个使用noLocal属性设置为true的使用者(请参阅版本1.7.4的RabbitTemplate #doSendAndReceiveWithTemporary方法行1297 ....

回答 1 投票 1

@RabbitListener没有从队列接收消息

我正在使用@RabbitListner注释来接收来自RabbitMq队列的消息。虽然我已经完成了执行此操作所需的所有步骤(即在我的配置类中添加@EnableRabbit注释)并声明...

回答 1 投票 0

慢网络中的大RabbitMQ消息

我正在使用RabbitMQ与Spring AMQP大消息(> 100MB,102400KB)小带宽(<512Kbps)低心跳间隔(10秒)单个代理需要> = 200 * 8秒消耗...

回答 2 投票 2

具有多个路由键的Spring引导流绑定队列

我需要使用多个路由键绑定单个队列。我在application.properties中进行了配置:spring.cloud.stream.bindings.some-channel1.destination = exch spring.cloud.stream.bindings.some -...

回答 1 投票 1

SpringBoot RabbitMq解析框中的json消息自动

我有我的springboot应用程序连接到RabbitMQ队列,我按照指定的Json格式推送消息,例如:{“messageId”:“de5fe5a3-1831-4b87-891d-e7a4c29295b4”,“message”:{“listingId”:“ 2" },...

回答 1 投票 1

如何使用带有Jhipster的RabbitMQ创建新的队列?

我创建了一个新的jhipster微服务。我添加了RabbitMQ模块。它是功能性的。不过我想创建手动队列,我试图在CloudMessagingConfiguration中添加它...

回答 1 投票 0

使用Spring RabbitMessagingTemplate发布消息时验证交换,路由密钥

有没有办法在使用RabbitMessagingTemplate发送消息时验证交换和路由密钥/队列?目前,有一个默认的交换和路由键,空白字符串和...

回答 1 投票 1

如何配置RabbitMQ(在Spring Boot 2.x中),以便手动确认工作

所以我阅读了所有的例子,我有com.rabbitmq.client.Channel和@Header(AmqpHeaders.DELIVERY_TAG),但是当我尝试调用Channel.basicNack(long deliveryTag,boolean multiple,boolean ...

回答 1 投票 0

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