RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。
无法在 ASP.NET Core 6.0 微服务中使用 Steeltoe 和 RabbitMQ 来限制重试
我正在开发一个 ASP.NET Core 微服务应用程序,其中我利用 Steeltoe 包集成 RabbitMQ 来进行消息传递。我正在尝试实现一个最大次数的重试机制...
在 LINQPad 7 中使用 MassTransit 8 请求时出现 RequestTimeoutException
对 MassTransit 还是新手,在尝试在 LINQPad 脚本中使用 MT8 请求时遇到问题。我在 Docker 中本地启动了一个 RabbitMQ 管理实例,它与 .NET 控制台配合使用...
我想使用指定的路由键过滤rabbit mq队列消息,以下是我在application.properties中的配置: spring.cloud.stream.rabbit.bindings.subscription-changed-input。
amqp-cpp 库:channel->cancel(consumerTag) 似乎没有取消
我正在使用 AMQP-CPP 库(不是 amqp C 库)连接到 RabbitMQ。消费队列是有效的,发布也是如此。我不使用交换器或任何东西,只是一个队列上的一个消费者。当
MassTransit.PayloadNotFoundException
当我尝试使用消息时,我在rabbitmq管理中收到此错误: MT-故障-异常类型:MassTransit.PayloadNotFoundException MT-故障消息:未找到有效负载:MassTransit。
出现错误:RabbitMQ.Client.Exceptions.BrokerUnreachableException
我是rabbitMQ的新手。我在本地为rabbitMQ启用了TLS。作为其中的一部分,我在我的 WINDOWS 计算机上创建了证书(遵循 LINIUX 步骤),如 https://www.rabbitmq.com 中所述...
嗨,我正在尝试使用 scala 中的 akka-stream-alpakka-amqp 库在兔子消息中设置标头,但我无法使其工作并读取存储库,我看不到任何参考或我...
.NET 客户端无法通过端口 5671 上的 TLS 连接到 AMQP Windows Server 2019 标准版本 1809
我使用的是 Windows Server 2019 标准版本 1809 内部版本 17763.2803 我首先安装了Erlang 26.0(otp_win64_26.0.exe)。我已将 Handle.exe 添加到 PATH 中。我还添加了 ERLANG_HOME (值...
如果 RabbitMQ 服务器暂时不可用,如何重试启动 Apache Camel RabbitMQ 消费者路由器
我有一个简单的 Apache Camel 路线 from("spring-rabbitmq:myExchange?routingKey=foo&bridgeErrorHandler=true") .log("来自 RabbitMQ: ${body}"); 示例项目...
我有我的API,一些端点需要将请求转发到Celery。想法是拥有特定的 API 服务,基本上只实例化 Celery 客户端并使用 send_task() 方法,并单独的...
我正在尝试使用 Celery 从学校大学网站异步抓取课程注册信息。最终,我想构建一些东西,如果
RabbitMQ - 当消费者执行时间长于consumer_timeout时,消息不被处理
我有一个消费者,很多时候需要很长时间才能完成响应队列的过程。这是因为消费者管理大文件。所以,执行时间比
如何使用definitions.json在RBMQ中添加额外的主题权限
有人知道如何通过definitions.json配置文件为用户提供额外的主题权限(例如amq.topic)吗? (我知道可以通过管理控制台,但我不想...
我想设置一个超时时间,超过该超时时间后,出队的消息将自动被拒绝。 当我将一条消息出队时,我会等到它通过套接字传输并且另一方确认其接收...
我已经安装并启动了 RabbitMQ。该服务也在运行。但是,当我尝试在 Firefox 中打开管理界面时,出现以下错误: Firefox 无法与
如果 RabbitMQ 服务器暂时不可用,如何重新尝试启动 Apache Camel RabbitMQ 消费者路由器
我有一个简单的 Apache Camel 路线 from("spring-rabbitmq:myExchange?routingKey=foo&bridgeErrorHandler=true") .log("来自 RabbitMQ: ${body}"); 示例项目...
我的rabbitmq应用程序在Windows 2012服务器上运行,我随机使用时出现此错误。 异常类型:RabbitMQ.Client.Exceptions.BrokerUnreachableException 没有指定的端点...
spring-boot应用程序尝试连接到在docker中运行的rabbitMQ时出现与连接相关的异常
我正在 spring-boot 中创建一个生产者和消费者,运行在 localhost:8081 上,它试图将消息推送到rabbitMQ。 我在 docker 中运行rabbitMQ。 我正在使用这张图片 -> rab...
我有一个基于 .NET 4.6.2 构建的 Windows 窗体应用程序。我使用下面的代码将应用程序连接到rabbitmq。 Rabbit mq 服务部署在单独的服务器上。 var 工厂 = 新
Spring boot 无法连接到 AmazonMq(rabbitmq)
嗨,我有一个运行rabbitmq的AmazonMq实例,但我无法使用spring boot连接到代理。 我可以在本地连接rabbitmq,但不能连接amazonmq(rabbitmq)。我的 Spring Boot 配置...