spring-amqp 相关问题

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

RabbitMQ DirectMessageListenerContainer中的消费者 - Cloud Foundry中的内存影响

我有一个场景，我在DirectMessageListenerContainer bean中为队列创建预定义的使用者，如下所示：@Bean public DirectMessageListenerContainer ...

spring-boot rabbitmq cloudfoundry spring-amqp

回答 1 投票 0

Spring AMQP项目没有做任何事情

我已经困扰了这项任务好几天了，所以我决定在这里问一个问题。好吧，我有一个远程RabbitMQ服务器，我只有发送和接收消息的权限。那意味着我......

java spring rabbitmq spring-amqp

回答 1 投票 0

如何使用@Payload将发布者消息绑定到我的Receiver中的自定义类

在我的应用程序中，我将从FileProcess服务之一发布消息（它将处理CSV文件并将其转换为CSVPojo并使用RabbitTemplate发布到队列.rabbitTemplate ....

spring-boot spring-batch spring-amqp

回答 1 投票 -1

Spring amqp批处理接收消息

我们使用Spring AMQP从RabbitMQ读取消息，现在我们一次只读取一条消息离开队列，无论如何我可以从队列中读取多条消息然后处理批处理？我知道了 ...

rabbitmq spring-amqp

回答 1 投票 3

Spring AMQP中的消息重试策略

我正在使用spring-amqp在我的Web应用程序中使用来自RabbitMQ的消息。 Web应用程序由多个组件组成，例如（Redis，OracleDB）现在我有一个场景，如果有的话......

spring-mvc spring-amqp spring-rabbitmq

回答 1 投票 2

Spring AMQP AcknowledgeMode.AUTO运行缓慢

我有一个生产者，每秒向RabbitMQ发送20条消息，而且我有一个消费者，它应该接收与它们产生的速度相同的消息。我有一些条件......

java spring amqp spring-amqp

回答 1 投票 2

从队列中消耗时，所有布尔字段都为false

我正在使用RabbitMQ发布包含一些布尔字段的有效负载的消息：class EntityDto {String name; int order; boolean isEnabled = true; //生成的setter和...

java rabbitmq spring-amqp

回答 1 投票 1

tomcat服务器依赖于rabbitmq服务器

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

spring-mvc spring-amqp spring-rabbitmq

回答 1 投票 0

访问被拒绝 - 使用认证机制PLAIN RabbitMQ Queue拒绝登录

我正在尝试使用RabbitMQ从一个应用程序发布消息并在另一个应用程序中接收它们。我可以使用localhost发布消息。例如：amqp：// guest：guest @ localhost：5672当我尝试...

java rabbitmq spring-amqp spring-rabbit

回答 1 投票 1

Spring-Kafka Consumer KafkaListener无法将GenericMessage转换为Java Object

我通过在Centos7实例上的Confluent-3.3.0平台上运行的kafka-rest服务发布一些自定义Java类型'InventoryEvent'的事件，使用以下两个步骤：命令POST POST JSON ...

spring-boot apache-kafka spring-amqp spring-kafka

回答 1 投票 1

Spring Boot没有连接到RabbitMQ

更新：在https://github.com/justsomecoder/boot-rabbit-issue上发布了非工作版本我试图实现一些基本的RabbitMQ发送和接收功能，但似乎无法得到它...

java spring spring-boot rabbitmq spring-amqp

回答 1 投票 1

如何配置Spring Amqp @RabbitListener在队列不存在时不抛出异常？

这是我的@RabbitLister代码：@RabbitListener（queues = device。*）我希望这个监听器监听由我的代理上的设备创建的所有队列，其中*是设备的ID，如：device.1当前，...

amqp spring-amqp

回答 1 投票 0

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

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

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

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

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

spring aspectj spring-amqp spring-rabbitmq

回答 2 投票 1

使用spring-rabbit-test for Junit

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

java spring spring-boot spring-amqp spring-rabbitmq

回答 1 投票 2

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

我有一个SimpleRabbitListenerContainerFactory定义如下：@Bean public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory（ConnectionFactory connectionFactory）{...

spring spring-amqp spring-rabbitmq

回答 1 投票 1

Spring Integration Rendezous通道确认速度慢

我有一个dsl流程，可以很好地使用Queue通道。但是，当我使用Rendezvous通道使其同步时，我获得最多30条消息/秒的确认率。我的处理程序只需......

spring-integration spring-amqp spring-dsl

回答 1 投票 1

@RabbitListener可以按条件申请

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

rabbitmq spring-amqp spring-rabbit

回答 1 投票 0

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

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

rabbitmq spring-amqp spring-rabbit spring-rabbitmq qpid

回答 1 投票 1

@RabbitListener没有从队列接收消息

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

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

spring-amqp 相关问题

最新问题