rabbitmq 相关问题

RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。

[MessageListener.onMessage在带有Spring Boot的RabbitMQ上不断被调用

我有带线程睡眠的MessageListener.onMessage。我正在模拟onMessage方法将由上述线程睡眠占用的实际处理时间。但是我注意到的是...

回答 1 投票 0

RabbitMQ:将邮件从“答复”队列复制到另一个队列

我主要在RPC模式下使用RabbitMq,但我也想将请求和响应消息都复制到另一个队列。最后,我要实现的是外部消费者的可能性...

回答 1 投票 0

正确使用SpringRabbit DirectMessageListenerContainer和setConsumersPerQueue属性

我使用DirectMessageListenerContainer来监听各个队列,因为它会为每个队列创建一个使用者,如果说“ queue1”的消息需要花一些时间来处理,则可以防止队列不足,而...

回答 1 投票 0

是否可以整合Rabbitmq和kafka?

我正在尝试在POC中需要连接RabbitMQ和Kafka。我的问题是是否可以连接RabbitMQ和Kafka?在此先感谢

回答 1 投票 1

RabbitMQ:从交换中解除队列是否影响客户端连接

从RabbitMQ中的交换解除绑定队列是否以任何方式影响使用者与该队列的连接?我想从交换中取消绑定队列,而不会丢失该队列中的消息或...

回答 1 投票 1


Rabbitmq node.js amqplib客户端PRECONDITION-FAILED异常

我尝试了assertQueue,在许多情况下,我不知道它在上下文中是什么意思。但是每次我都有同样的例外!我想要的只是听一些队列并开始...

回答 1 投票 0

如何清除RabbitMQ中排队的消息

我处于无法从Que清除消息的情况(请参阅上图),而且我不确定它们属于哪个队列,因此我如何确定该消息以及如何清除这些已排队的消息...] >

回答 1 投票 0

RabbitMQ语法中的哈希符号是什么意思?

我是一名初级开发人员。以下代码是Express代码。可能引发一个socket.io事件。 myEventServiceBus.subscribe('FooMessage',appName,['abc.xyz。#'],onMessage)我不确定是否#是...

回答 1 投票 0

EasyNetQ消费消息中的异常

我正在使用easyNetQ从队列发布和接收消息,但是..从队列获取消息中的异常。服务器报告了0条消息Exchange错误Exchange_类型:EasyNetQ ....

回答 1 投票 1

Spring AMQP恢复器不适用于SimpleMessageListenerContainer

我正在尝试在春季amqp中实施恢复。我使用下面的代码来实现相同的RetryOperationsInterceptor retryInterceptorBuilder = RetryInterceptorBuilder.stateless()...

回答 1 投票 1

MassTransit / Rabbit MQ版本兼容性

MassTransit版本在发布之前是否已针对Rabbit MQ的特定版本进行了测试和认证?如果是,是否发布了此信息?

回答 1 投票 0

将具有队列的单租户应用程序移动到多租户Web应用程序

我需要将单租户(.net核心)Web应用程序移至多租户(约100个租户)Web应用程序。租户将共享相同的应用程序,但每个租户将拥有其自己的...

回答 1 投票 0

带有WSL和python的RabbitMq

我已经通过WSl(与商店)在Ubuntu 18.4上安装了RabbitMq。下载了最后一个稳定的发行版,如deb,然后下载了sudo apt-get install -f来修复依赖性。然后我创建了一个.py文件...

回答 1 投票 2

无法连接到代理错误,连接被对等方重置

[当我把芹菜拖尾时,我得到:消费者:无法连接到amqp:// guest:** @ [NEW_INSTANCE_IP]:5672 //:[Errno 104]由对等方重置连接。请在32.00秒内重试...当我拖尾我的花朵时,我...

回答 1 投票 0

RabbitMQ 2队列

看到类似的问题,但预期答案不同。我的问题是,我是否可以创建一个消费者以专注于单个队列,直到它清空后再切换到另一个队列,直到将新工作发送到...

回答 1 投票 0

如何在iAPC中使用RabbitMQ用户访问管理?

我正在iAPC(Swisscom应用程序云)中设置新的RabbitMQ服务,我需要控制不同生产者/消费者应用程序的用户访问权限。我的访问控制要求:应用程序A ...

回答 1 投票 1

无状态服务之间的Service Fabric发布/ 订阅消息传递

什么是使用异步消息传递在Service Fabric中实现松耦合微服务的最佳方法。我希望服务A发布一条消息,并让服务B接收它。我可以使用rabbitmq还是...

回答 1 投票 0

apache-camel rabbitmq ssl集成不起作用

我们正在使用apache-camel与Rabbitmq连接。现在,我们计划使用https连接Rabbitmq。我按照步骤使用https://www.rabbitmq.com/ssl.html启用Rabbitmq到https。现在...

回答 1 投票 0

饥饿的Python工作者中的内存泄漏

我有几个工作人员正在侦听RabbitMQ队列,并且正在做一些磁盘I / O密集型工作-打开〜18MB的文件,进行一些解析并写入一些文件。处理一个作业时...

回答 1 投票 2

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