RabbitMQ是一个开源消息代理，最初实现AMQP协议，并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用，或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的，以及正在使用的OS和编程语言。
Spring Cloud Stream Rabbit 使用 ssl 启动时出错
我正在尝试使用Spring cloud Stream从aws（AmazonMQ）连接rabbitmq，并使用ssl连接spring-cloud-stream-binder-rabbit，但是在启动应用程序时出现错误，我不需要
Nestjs Rabbitmq 将 env 变量与 @golevelup/nestjs-rabbitmq 包一起使用
我尝试使用@golevelup/nestjs-rabbitmq连接到rabbitmq并消费消息。我想在 @RabbitSubscribe 方法中使用环境变量。他们总是未定义并寻找
我有一个大型项目，遵循干净的架构解决方案布局和一些领域驱动设计/CQRS 方法。我关注了 Milan Jovanovic 早期的干净建筑 Youtube v...
以下对 RabbitMQ 的 API 调用： http -a 用户：PASS 本地主机：15001/api/queues/ 返回队列列表： [ { ... “messages_unacknowledged_ram”：0， “名称”：“foo_...
我是 EasyNetQ 的新手。考虑将这个库采用到我的项目中。 我有一个关于消费消息的问题。维基百科指出： “当消息从通过
我正在使用 aio_pika，并且在拒绝来自队列的消息时，rabbitMQ 订阅工作程序遇到了问题。我拒绝了队列中的消息并交换到死信队列。消息已到达死者...
RabbitMQ使用Spring boot，如果队列不存在则应创建
我正在从多个源向RabbitMQ发送数据，如果队列不存在，我想创建它。 公共无效sendMessage（字符串消息，字符串路由键）{ rabbitTemplate.convertAnd...
使用 Azure AD Oauth 非交互式登录 RabbitMQ
最近，我们根据本指南 https://www.rabbitmq.com/oauth2-examples-azure.html 在 Azure AD 中为 RabbitMQ 实例设置 OAuth 授权。 交互式授权对于 AD 用户来说效果很好（w...
Quarkus - SmallRye 反应式消息传递 - RabbitMQ：将消息发送到默认交换
使用远程过程调用模式，我需要将答案发送到回复队列，即我需要将消息发送到默认交换机，并以队列名称作为路由键。 我正在使用...
当我运行带有rabbitmq的docker-compose容器时，没有这样的虚拟主机错误
我需要创建一个 docker-compose 文件，以便在启动容器后立即有一个“myqueue”队列，我可以立即开始使用它。 我使用 docker-撰写： 版本...
如何托管 NextJs（前端）、Express（后端）和 Firebase（数据库）堆栈应用程序？
我有一个应用程序需要使用 RabbitMQ 与 RasberryPI 进行通信，因此我计划在 Express 后端中使用 amqplib，并且我有一个用于离线使用的图像、日志和数据的数据库。 ...
Spring AMQP/RabbitMQ - java.net.SocketException：连接被对等方重置（写入失败）
我在 Kubernetes 集群中有一个 RabbitMQ 服务器，我使用具有默认设置和 RabbitTemplate 类的 Spring AMQP 连接到该服务器。 我在发送方 Spring Boot Microser 中有一个预定的方法...
程序运行 Pika 抛出 AMQPConnectionError
浏览此处的 Rabbit MQ Pika HelloWorld 教程： https://www.rabbitmq.com/tutorials/tutorial-one-python.html 问题是，每当我运行接收脚本时，我都会收到此错误...
我正在尝试在 AWS EC2 上的 Ubuntu 实例上运行我的 django 服务器。我正在使用 Gunicorn 来运行服务器，如下所示： Gunicorn --workers 4 --bind 127.0.0.1:8000 woc.wsgi:application --name woc-s...
rabbitmq是否支持通过ttl和dead letter对不同的ttl消息进行延迟队列？
为什么我收到的消息在 20 分钟 ttl 消息之前设置了 10 分钟 ttl，而该消息比 10 分钟 ttl 消息早发送？ 我希望首先收到 20 分钟的消息，然后再收到 10 分钟的消息。 ...
Python - RabbitMQ Pika 消费者 - 如何使用异步函数作为回调
我有以下代码，我在其中初始化侦听队列的消费者。 消费者=我的消费者() Consumer.declare_queue(queue_name="my-jobs") Consumer.declare_exchange(exchange_name=...
从 Activity 发送数据到 RoutingSlipCompleted 使用方法
我在活动中有一些数据，我想在 RoutingSlipCompleted 使用方法中获取它。我知道我们可以使用 CompletedWithVariables 将数据从活动发送到活动 b。但我想知道ho...
RabbitMQ 和 Docker：创建线程失败：不允许操作（1）
我在具有多个服务的 docker swarm 中使用 RabbitMQ，所有其他服务都启动正常，但 RabbitMQ 容器没有，并且日志显示以下错误： 未能成功...
rabbitmqctl 显示nodedown，但如果我使用 Invoke-Command 并提供计算机名称则不会显示
我在 Windows Server 2008 R2 上安装了 RabbitMQ 3.6.5 / Erlang 18.0。我知道我的 RabbitMQ 节点“rabbit@447523-testap01”已启动，因为我可以使用管理 UI 连接到它。如果我运行
当尝试解决我无法使用 Rebus 通过 RabbitMQ 接收消息的问题时，我尝试使用此示例：https://github.com/rebus-org/RebusSamples/tree/master/PubSubNative 并发现...