spring-rabbitmq

2热度

1回答

创建一个具有2个消费者和多个端点的单个RabbitListenerContainerFactory来监听消息的行为

我有一个要求，我有1个直接交换，并且5个不同的队列通过唯一的路由键绑定到它。基本上每个队列都是针对不同的消费者端点。我正在使用弹簧托管端点注册表，使用@RabbitListener。所以有5个端点注册。在我实现它的时候，我创建了一个RabbitListenerContainerFactory，其值为concurrentConsumer。但是我有一个问题，如果有一个工厂创建的消费者规模为2，那么所有

1热度

2回答

SimpleMessageListenerContainer一样 - 消费引发的异常，如果连接工厂支持它

我不断收到在我的春天RabbitMQ的消费方以下警告处理可以重新启动。它一直在寻找重新启动。 [SimpleAsyncTaskExecutor-3317] WARN org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Consumer raised exception, processing can r

1热度

1回答

在SimpleMessageListenerContainer上使用addQueueNames需要更多时间

我们使用SimpleMessageListenerContainer（（max）consumer count为75）。我们有一个用例，我们需要动态订阅和取消某些队列的订阅，因此我们使用addQueueNames（）和removeQueueNames （）。当消费者数量为75时，addQueueNames（）方法需要大约15秒才能完成。我们目前有大约200个队列。我们想要经常添加和删除监听器中的队列

0热度

1回答

RabbitMQ配置脚本

我有一个兔子配置文件，它包含一个JSON。据我所知，通过使用我可以配置RabbitMQ，但我不知道我必须把该文件或如何运行它。 { "rabbit_version": "3.5.6", "users": [{ "name": "guest", "password_hash": "GAd/n+dflOQhAEnqkF6y2V0TMrU=",

0热度

1回答

无法为推送通知启用/监控弹簧云总线端点

我配置了spring cloud config以从git存储库读取属性。对于当前实现，如果配置发生更改，如果发布到/ refresh on我的客户我能够看到更新的属性。现在，我想使用spring-cloud-bus-monitor来检测我的git repo中的更改并自动刷新客户端端点中的属性。即使在依赖关系中添加spring-cloud-config-monitor之后，/ monitor端点也未

0热度

1回答

SimpleMessageListenerContainer一样回采后无法恢复

当某个事件到来时，我停止我的rabbitmq listner使用container.stop();和必要的工作完成后，我重新启动它与container.start()，但是，当一个新的事件到来时，我得到以下错误： Exception in thread "SimpleAsyncTaskExecutor-1" 2016-04-22T16:20:53.646 WARN 15336 --- [cTask

1热度

1回答

如何在测试配置中使用相同的bean但具有不同的属性？

我有单独的配置类，根据Spring Profile创建不同的bean。我希望我的测试尽可能模拟生产代码，因此我想使用在Spring ‘PROD’ Profile下创建的相同的豆类，但添加/更新专门用于测试的不同属性。什么是实现这一目标的最佳方式？我的意思例子： @Profile(PROD) public class ProdConfig { @Bean public Sim

0热度

1回答

在RabbitMQ中注入服务 - ConfirmCallback类不起作用

我创建了一个实现ConfirmCallback接口的独立回调类，并重写了confirm（）。相关数据和确认工作正常。但是我已经使用@Autowired注入了一个服务，以便在成功从rabbitMQ获得ack后执行其他一些活动。但该服务引用根本不被注入。我已经在其他工作正常的类中注入了相同的服务。我的代码 public MyConfirmCallback implements ConfirmCallb

1热度

2回答

是否有可能使用java应用程序将JSON对象传递给RabbitMQ队列？

我想将JSON对象传递给RabbitMQ队列。在下面的代码中，我使用obj.toJSONString().getBytes()将Json对象转换为字符串，是否有可能在队列中传递JSON对象而不是作为字符串传递。 JSONObject obj = new JSONObject(); obj.put("Transaction","Test value"); \t \t \t \t \t \t

1热度

1回答

如何确保我的应用程序连接到RabbitMQ是健康的

我需要设置keepalive端点以便可以web应用程序（tomcat war）。我的WAF会定期采样终点，以确保应用程序健康。健康应用程序意味着应用程序已启动，并且与RabbitMQ服务器（版本3.5.3/spring-rabbit 1.4.5）的通信已启动并且功能正常。我会打开一些REST API到我的WAF来验证连接状态。阅读文档我很遗憾如何实现这个功能。我注意到一些功能，可以帮助，