rabbitmq 相关问题

如何使用 .NET Core 7 控制台向 MassTransit 消费者发送数据

我的解决方案中有两个项目，一个是控制台，另一个是API。在 API 项目中，我按如下方式设置 MassTransit： 使用大众运输； 使用通知； var builder = WebApplication.

Celery 任务未在 Mac M2 上运行（进程“ForkPoolWorker”退出并显示“信号 11 (SIGSEGV)”）

我在尝试在 Mac M1 计算机上运行 Celery 任务时遇到问题。我收到的错误消息如下： 进程已分叉，您无法使用此 CoreFoundation 功能...

如何使用 AWS Systems Manager (SSM) 访问 AWS VPC 私有子网中的 RabbitMQ 代理

我目前正在致力于在 AWS 私有子网中设置 RabbitMQ 代理并使用 AWS Systems Manager (SSM) 安全地访问它 注意：工作解决方案：我已经尝试过在

RabbitMQ 消息生命周期重播消息

我们目前正在评估 RabbitMQ。尝试确定如何最好地将我们的某些流程实现为消息传递应用程序，而不是传统的数据库存储和抓取。这是场景。我们有一个

Rabbitmq-设计消息重放服务

我正在尝试设计一种重播机制，使用户能够重播队列中的消息。 我为包含多个队列和多个消费的交换提出的最佳设计......

RabbitMq 重播限制

我需要使用rabbitmq来满足客户的需求。客户建议rabbit mq。 根据一些谷歌搜索，rabbitmq 似乎不支持从任意偏移量重播过去的消息，不像……

spring-boot-starter-amqp 依赖导致 CglibAopProxy 在调用 CachingConnectionFactory.createConnection() 时抛出 AmqpException

我正在尝试将rabbitmq嵌入到Spring Boot应用程序中。我遵循了互联网上的各种教程。 使用的spring boot版本是V2.7.14。我的 POM 中有 spring-boot-starter-amqp

RabbitMQ 消息在抛出 AmqpRejectAndDontRequeueException 后仍然重试

我有一个简单的 Spring Boot 应用程序，其中有以下 RabbitMQ 设置（spring-boot-starter-amqp 版本是 2.7.0）： 春天： 兔子MQ： 主机：本地主机 端口：5672 虚拟...

Spring amqp 死信交换与多个队列绑定

在我的应用程序中，使用两个队列，它们与一个带有密钥的交换器绑定.. 与此键正则表达式匹配的任何消息都将进入两个队列。 案例 2：我正在尝试实施...

错误：频道已结束，不会有回复

我正在尝试在流星应用程序中使用 wascally (npm)，并且我已经设置并运行了它。但是，我尝试使用 request() 函数并在其上链接 then() 语句来处理

MassTransit RateLimit，一个队列上有多个消费者

我正在寻求有关 UseRateLimit(...) 功能如何在以下情况下工作的说明：我们有许多消费者共享同一队列。每个消费者都有自己独特的混乱......

如何从 WSO2 MI 4.2 中的 RabbitMQ 入站端点消息中提取队列名称、优先级和消息 ID？

我目前正在使用 WSO2 Micro Integrator (MI) 4.2 开发一个项目，我在其中设置了一个入站端点来使用来自 RabbitMQ 的消息。在这种情况下，我需要提取特定的元数据

RabbitMQ 控制台返回 431

我使用以下命令在 docker 上启动rabbitmq： docker run -d --主机名 my-rabbit --namerabbit-fox -p 5672:5672 -p 8090:15672rabbitmq:3-management 它运行良好，我可以登录控制台，但稍后

用于 AMQP 的优秀 Python 库 [已关闭]

您能推荐使用什么Python库来访问AMQP（RabbitMQ）吗？根据我的研究，鼠兔似乎是首选。

在 Spring Cloud Stream 中应用动态组值

如何动态为流绑定器提供组值，以在使用 Spring Cloud Stream 时实现灵活性。我怎样才能实现这个目标？

RabbitSubscribe 一次消费一条消息

我正在使用nestjs goleveluprabbitmq库，想知道是否可以使用RabbitSubscribe但一次只消费一条消息？目前它会在...之前收到多条消息

Spring Cloud Stream Rabbit Binder 动态组名称

使用Spring Cloud Stream时，我需要动态地将组值赋予绑定器，我该怎么做？

无法连接到rabbit mq

我正在编写一个用于连接到 RabbitMQ 的控制台应用程序，并将其作为 Docker 容器上的映像运行。 我的图像在端口 15672 上运行，当我浏览到 http://localhost:15672/#/ 时。我可以登录

Spring 无法为 RabbitMQ 自动装配 ConnectionFactory

我正在尝试遵循这个简单的 Spring RabbitMQ 消息传递指南。 我有两个关于自动装配的问题： 无法自动装配。未找到“ConnectionFactory”类型的 bean 无法自动装配。没有豆子...

RabbitMQ：通过一致的哈希交换扩展队列

（从 Github 问题中获取） 我们使用 RabbitMQ 的一致性哈希交换，这对于将路由键从交换器分片到多个队列非常有用。 我们利用队列向工人分发工作。