Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
为什么我无法使用 python 建立与rabbitMQ的连接?
我正在学习如何使用rabbitMQ 我正在 MacBook 上运行rabbit MQ 服务器并尝试与 python 客户端连接 我按照安装说明进行操作here http www rabbitmq com install homebrew h
python
rabbitmq
amqp 与 amqplib - 哪个 Node.js amqp 客户端库更好?
这些 amqp 客户端库之间有什么区别 哪一款最值得推荐 主要区别是什么 我会推荐amqp node https github com squaremo amqp node and bramqp https github com bakke
nodejs
rabbitmq
AMQP
在使用 FromEventPattern 订阅之前捕获事件
我正在使用 Rx 框架编写消息监听器 我面临的问题是 我正在使用的库使用一个消费者 每当消息到达时就会发布事件 我已经设法通过以下方式消费传入的消息Observable FromEventPattern但我对服务器中已有的消息有疑问 目前我
c
NET
rabbitmq
systemreactive
Camel 中的无限循环 - Rabbitmq
我有一个小型服务器路由 它从queue in 获取消息并放入queue out 当我输入一条消息时queue in 服务器无限循环运行 我想知道我在配置方面缺少什么 这看起来是一条非常简单的路线 小服务器路由
apachecamel
rabbitmq
Airflow Worker 没有监听默认的 RabbitMQ 队列
我已经使用rabbitmq代理配置了Airflow 服务 airflow worker airflow scheduler airflow webserver 正在运行 没有任何错误 调度程序正在推动任务执行default兔子MQ队列 即使
rabbitmq
airflow
RabbitMQ 用户在预先创建的队列上发布/订阅的权限
我有一个用例 我需要创建一个用户并授予他仅在现有队列上发布 订阅的权限 这是一个示例 虚拟主机 mainvhost 对于所有用户都相同 在虚拟主机内 我有 A foo 和 Q bar 队列 用户 foo 只能发布 订阅到 Q foo 用户
permissions
rabbitmq
AMQP
spring中rabbitmq监听器的异常处理
使用spring 我是rabbitmq的新手 我想知道我错在哪里 我编写了一个rabbitmq连接工厂和一个包含侦听器的侦听器容器 我还为侦听器容器提供了错误处理程序 但它似乎不起作用 我的春豆
SpringMVC
rabbitmq
springrabbit
如何优雅地结束 spring @Schedule 任务?
我正在尝试让 Spring Boot 服务优雅地结束 它有一个方法 Scheduled注解 该服务使用 spring data 作为数据库 使用 spring cloud stream 作为 RabbitMQ 在计划的方法结束之前 数据库和
Java
Spring
springboot
rabbitmq
springscheduled
RPC 模型中的correlationId 和临时队列 - AMQP
我正在读书RPC模型 http www rabbitmq com tutorials tutorial six java html在 AMQP 中使用 RabbitMQ 本教程创建了一个临时队列 并且还correlationId 临时队列是
rabbitmq
rpc
AMQP
RabbitMQ 中的并发
经过一周的编码和搜索论坛后 似乎是时候问 我有一个 C 应用程序 它使用 EventingBasicConsumer 处理 RabbitMQ 发送的消息 我想同时处理多个消息 因此我在同一连接上实例化了几个通道 本例中为 8 个 每个通道都
c
Multithreading
concurrency
rabbitmq
每次发送消息时是否需要重建RabbitMQ连接
我有一个 Spring 3 应用程序 它通过非 RabbitMQ 接收器接收消息 处理它们并通过 RabbitMQ 转发 每次发送消息时都会建立一个新的 RabbitMQ 连接 这似乎有点浪费 我只是想知道这是否真的有必要 或者是否有原因导
Java
Spring
rabbitmq
使用RabbitMQ(Java客户端),有没有办法确定消费期间网络连接是否关闭?
我在 RHEL 5 3 上使用 Java 客户端使用 RabbitMQ 我有 2 个节点 机器 Node1 正在使用 Java 帮助器类 QueueingConsumer 消费 Node2 上队列中的消息 QueueingConsumer
Java
rabbitmq
AMQP
Symfony Messenger 和 Mailer:如何添加绑定密钥?
我有一个正在运行的 Symfony 4 4 项目 其中包含Messenger和rabbitMQ 我有一个带有 2 个队列的异步传输 transports https symfony com doc current messenger htm
Symfony
rabbitmq
symfony4
symfonymessenger
symfonymailer
Spring RabbitMQ 教程导致连接被拒绝错误
我是一名经验丰富的 Java 程序员 并且是第一次尝试 Spring Rabbit MQ 我遵循了 messages rabbitMQ 教程exactly使用 Maven http spring io guides gs messaging
Java
Spring
rabbitmq
springamqp
使用 STOMP 连接 RabbitMQ 时如何重播丢失的消息?
我有一个 iOS 应用程序 它使用STOMP客户端 https github com juretta objc stomp交谈RabbitMQ https www rabbitmq com 应用程序在启动期间加载大量状态 然后通过接收 ST
Objectivec
rabbitmq
stomp
“目录名称无效。”等等,在Windows上使用rabbitmq-plugins
我正在尝试通过以下方式让 RabbitMQ 在 Windows 10 上运行这些说明 http arcware net installing rabbitmq on windows 但是 当尝试通过 powershell 命令启用管理插件时
rabbitmq
Windows10
Quarkus - SmallRye 反应式消息传递 - RabbitMQ:将消息发送到默认交换
使用远程过程调用 https www rabbitmq com tutorials tutorial six java html模式 我需要将答案发送到回复队列 即我需要将消息发送到默认交换机 并以队列名称作为路由键 我在 Quarkus
rabbitmq
quarkus
smallryereactivemessaging
如果芹菜工人死了,工作会重试吗?
如果运行工作程序的服务器挂掉 是否有办法重试 celery 作业 我指的不仅仅是执行作业的子进程 而是整个服务器变得不可用 我尝试使用 RabbitMQ 和 Redis 作为代理 在这两种情况下 如果当前正在处理作业 则它会被完全遗忘 当工
Redis
rabbitmq
Celery
MassTransit/RabbitMq 错误队列 - 如何删除消息?
我有一个队列 QueueName 我定义了消费者和错误消息消费者如下 cfg ReceiveEndpoint queueName QueueName e gt e UseMessageRetry r gt r Immediate 2 e A
c
rabbitmq
masstransit
.NET 中带有 Unity IOC 容器的 RabbitMQ
我使用 Unity App Block 作为 WCF 项目服务层的 IOC 容器 使用 Unity WCF 库将其插入到每个 WCF 服务中 效果非常好 我最近将 RabbitMQ 引入了我的服务层 目前我正在使用 using 块来连接并添
NET
rabbitmq
unitycontainer
«
1
2
3
4
5
6
7
8
...40
»