RabbitMQ队列的可轮询StreamListener或MessageSource
我有Spring Cloud Stream Rabbit项目，它将消息发送到兔子交换errorEx以防流中出现错误。我想定期（5分钟一次）从队列中监听并处理它。
有什么方法可以让我有一个可轮询的@StreamListener？或者我可以配置一个RabbitMQorg.springframework.integration.core.MessageSource，这样我就可以用轮询器构建一个IntegrationFlow？
共有1个答案
Spring集成AMQP不提供可轮询的适配器@StreamListener仅支持可订阅的频道。
您可以使用自定义的消息源，该消息源使用rabbitmplate（）操作来获取消息。
或者，您可以根据需要使用消息驱动适配器和它。
-
我有一个WebJob，当用户将文件上传到blob存储时触发 - 它由队列存储消息触发，该消息在上传完成后创建。 根据文件的用途，它将向其他队列发送消息以触发处理作业。 这些作业中的一些是时间关键的，并且运行相对较快。在一种情况下，处理过程需要大约三秒钟，用户正在等待结果。 但是，因为最小队列轮询间隔是2秒，所以用户必须等待两个WebJobs被调用的时间通常是等待时间的两倍。 我尝试将两个WebJo
-
一种方法是声明队列并将消息发布到该队列，并让所有使用者从该队列中消费。这将在不同的消费者之间分发消息。 我不清楚，如果上面的操作是正确的，或者最佳实践是将消息传递到Exchange而不是直接发布到队列。使用Exchange时，我必须确保在生产者创建Exchange之后声明队列，然后才开始发布消息。否则，没有队列接收到消息，并且消息将丢失。
-
需求：构建一个基于。NET的应用程序，该应用程序可以定期从IBM Websphere消息队列读取消息，并将这些消息保存到数据库中
-
问题 你有一个线程队列集合，想为到来的元素轮询它们， 就跟你为一个客户端请求去轮询一个网络连接集合的方式一样。 解决方案 对于轮询问题的一个常见解决方案中有个很少有人知道的技巧，包含了一个隐藏的回路网络连接。 本质上讲其思想就是：对于每个你想要轮询的队列，你创建一对连接的套接字。 然后你在其中一个套接字上面编写代码来标识存在的数据， 另外一个套接字被传给 select() 或类似的一个轮询数据到达
-
在队列选项卡的rabbitMQ web界面上，我看到了“概述”面板，我在其中找到了以下内容： 排队消息： 准备好了 未确认 总数 我猜“总数”是多少。但什么是“准备就绪”和“未确认”？“准备好了”——传递给消费者的信息？“未确认”-？ 消息费率： 发表 交付 重新交付 承认 这些信息是什么？尤其是“重新交付”和“确认”？这是什么意思？
-
我正在使用他们的SQS队列服务为Amazon SES设置反弹、投诉和送货通知。 文档建议在轮询多个SQS队列时，在多个线程上进行轮询。使用长轮询时尤其如此，因为长轮询一个线程上的多个队列可能会导致轮询队列延迟来自不同队列的新消息。 因此，如果我想在我的ASP.NET MVC应用程序中轮询3个SQS队列，我是否应该像下面这样生成裸体线程： 或者是否有更好的方法来实现这一点，因为这是一个长时间运行的进