Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何使用 RabbitMQ 主机列表连接参数
我正在尝试使用IList
c
rabbitmq
AMQP
RabbitMQ 中的消息序列出现意外行为
我想实现类似于选项 3 的 RabbitMQ 拓扑here https engineering nanit com rabbitmq retries the full story ca4cc6c5b493 除了一些差异 新拓扑每天应该处理几
python3x
Docker
rabbitmq
pika
rabbitmqexchange
如何使用同一个工人让芹菜重试?
我刚刚开始在 Django 项目中使用 celery 并且有点陷入这个特定问题 基本上 我需要将长期运行的任务分发给不同的工作人员 该任务实际上分为几个步骤 每个步骤都需要相当长的时间才能完成 因此 如果某个步骤失败 我希望 celery
python
django
rabbitmq
Celery
RabbitMQ 中的主题交换与直接交换
我们有一个将使用 RabbitMQ 的应用程序 并且有几个不同的队列用于在层之间传递消息 最初 我计划使用多个直接交换 每种消息类型一个 但看起来使用不同路由键绑定的队列的单个主题交换将实现相同的效果 拥有一个单一的交换似乎也更容易维护 但
rabbitmq
MessageQueue
rabbitmqexchange
RabbitMq - ConversationId 与 CorrelationId - 哪个更适合跟踪特定请求?
RabbitMQ 似乎有两个非常相似的属性 我并不完全理解其中的区别 ConversationId and CorrelationId 我的用例如下 我有一个网站 可以生成Guid 该网站调用 API 将该唯一标识符添加到HttpReque
c
rabbitmq
masstransit
如何在 Rabbit.js 上创建 REP/REQ
我已经在 Net 上使用 RabbitMQ 一段时间了 并且没有遇到太大的问题 现在我正在使用 node js 迁移到rabbit js 但我对它不太熟悉 rabbit js 的文档有限 我只知道基本的 PUSH PULL 或 PUB SU
nodejs
rabbitmq
如何删除 Rabbitmq 以便我可以重新安装
我遇到了麻烦 所以我进入注册表并删除了rabbitmq的服务条目 现在 当我尝试重新安装时 它说它已经存在 但无法启动 因为我删除了它 我可以执行以下操作sc delete rabbitmq 如何完全删除它的所有痕迹并从头开始重新安装 我猜
rabbitmq
如何设置队列以使所有订阅者都能收到消息 - Rabbitmq
我正在阅读 RabbitMQ in Action 一书 仍在第 2 章中 但作者说的一件事让我感到困惑 您设置一个交换并发送一条消息 两个订阅者正在监听队列 当第一条消息到达时 第一个订阅者会收到它 并且一旦确认该消息就会被删除 当下一个消
rabbitmq
Celery 和 RabbitMQ - 队列优先级、消费者优先级、任务优先级
在我的 python 应用程序中 我使用 Celery 作为任务生产者和消费者 使用 RabbitMQ 作为代理 现在 我正在实施优先级 起初 它看起来根本不起作用 因为根据文档 我刚刚添加了x max priority队列的参数 我更深入
python
rabbitmq
Celery
当我尝试使用 pika (python) 向 RabbitMQ 确认消息时,出现错误“未知的传递标签”
我想在几个线程中处理消息 但在执行此代码期间遇到错误 from future import with statement import pika import sys from pika adapters blocking connecti
python
MessageQueue
rabbitmq
pika
如何为 RabbitMQ 连接设置自定义名称?
能够通过连接名称识别 RabbitMQ 客户端将非常有用 我正在使用 Spring Cloud Streams 抽象 并且使用默认设置我得到类似的东西 如何在 Spring Boot 客户端中设置自定义 RabbitMQ 连接名称 EDIT
rabbitmq
springcloudstream
将值添加到 MassTransit.RabbitMq 中的标头
我正在使用 MassTransit 3 0 0 0 我很难理解如何在请求 响应场景中拦截消息 并将一些信息添加到我可以在接收器端读取的标头字段 我正在看中间件 http masstransit project com MassTransit
rabbitmq
masstransit
Spring Boot RabbitMQ 接收器 Jackson 反序列化为 POJO
我有一个 Spring Boot 项目 我正在尝试与 RabbitMQ 服务器集成 以便我可以向队列发布消息和从队列读取消息 这是我的rabbitmq配置 编辑后仅显示相关详细信息 Configuration ConfigurationPr
Java
json
Spring
Jackson
rabbitmq
Pika:写入缓冲区超出警告
我们的软件程序运行良好 5 个月 现在突然开始收到 Pika 警告 最终导致异常 Pika 0 9 5 用户警告 写入缓冲区超出警告阈值 我搜索了很多论坛 但都不满意 所描述的一种解决方案是完全忽略这些警告 但我对此有点怀疑 对此问题的任何
python
rabbitmq
pika
消息传递的幂等性屏障
最近推介会 http www slideshare net leastfixedpoint achieving scale with messaging and the cloud 20090709我看到关于RabbitMQ http ww
Java
MessageQueue
Messaging
rabbitmq
缺少rabbitMQ配置文件
我正在使用 Rabbitmq 3 7 2 和 Erlang 20 2 并且 bydefualt RMQ 配置文件丢失 在以下路径 C Users vxadmin AppData Roaming RabbitMQ config 基于我采取的步
rabbitmq
如何使用 MQTT Paho 在 RabbitMQ 队列中订阅
我正在尝试从我的 Android 应用程序连接到一个名为 消息 的队列 生产者 AMQP 协议下的一种 Web 服务 已连接 可以通过 RabbitMQ 管理面板进行检查 为了从我的 Android 设备进行连接 我正在这样编码 priva
rabbitmq
mqtt
Rabbitmq消息到达时间戳
有没有办法从消费者那里获取消息放入队列时的时间戳 不是当它发布的时候 而是当它真正进入队列的时候 不 没有办法解决这个问题 除非 正如您自己所说 您为此编写了一个插件 AMQP 中没有任何内容规格 http www amqp org sit
c
rabbitmq
AMQP
Rabbitmq-设计消息重放服务
我正在尝试设计一种重播机制 使用户能够重播队列中的消息 对于包含多个队列和多个消费者的交换器 我提出的最佳设计是 创建一个记录器服务 它将 创建一个队列并将所有路由键绑定到它 消耗来自交换器的所有消息 将所有消息保存到数据库 订阅者请求重播
rabbitmq
MessageQueue
Replay
如何在 EasyNetQ 中为每个消费者声明自定义错误交换?
我有四个消费者 当错误发生时 消息发布到默认的 EasyNetQ Default Error Queue 是否可以让每个队列消费者编写自己的错误交换 例如 Queue Name A ErrorExchange A ErrorExchange
c
rabbitmq
consumer
easynetq
«
1 ...
3
4
5
6
7
8
9
...40
»