Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Mule AMQP 传输 3.6.2 社区可能存在的错误
我一直在追踪一些奇怪的行为 最终成功地将其隔离 我相信这是一个错误 为了重现该行为 我创建了 4 个测试流程 在 4 个不同的 mule 文件中
Mule
AMQP
如何指定使用Spring Cloud Stream向RabbitMQ发送消息的超时?
我们在发送消息的过程中遇到了网络问题 这导致所有线程都处于阻塞状态 我们正在使用org springframework cloud spring cloud stream 2 0 1 RELEASE and org springframew
Java
rabbitmq
springintegration
AMQP
springcloudstream
Celery (Django) 速率限制
我正在使用 Celery 来处理多个数据挖掘任务 其中一项任务连接到远程服务 该服务最多允许 10 个同时连接per user 或者换句话说 它CAN全球连接数超过 10 个 但CANNOT每个单独作业超过 10 个连接 I THINK 令
rabbitmq
AMQP
Celery
carrot
使用react\stomp仅消费来自RabbitMQ的N条消息,分别确认它们,然后退出
我正在将 RabbitMQ 与 PHP React stomp 结合使用 我有两个队列 一个是 todo 另一个是 done 消费者读取 todo 完成工作 确认消息 然后将其发布到 done 队列 有什么方法可以确保我只消耗来自 todo
rabbitmq
AMQP
stomp
reactphp
AMQP/RabbitMQ - 顺序处理消息
我有一个direct交换 还有一个队列与该交换器绑定 该队列有两个消费者 消费者完成相应的处理后 将手动确认消息 消息按逻辑顺序 排序 并且应按该顺序进行处理 是否可以强制要求消费者 A 和消费者 B 按顺序接收和处理所有消息 换句话说 阻
rabbitmq
AMQP
highavailability
Spring-AMQP重新排队消息计数是基于JVM的吗?
我正在研究rabbitmq文档 似乎rabbitmq不处理消息重新传递计数 如果我要手动 ACK NACK 消息 我需要将重试计数保留在内存中 例如 通过使用关联 ID 作为映射中的唯一键 或者通过在消息中设置我自己的标头 然后重新传递它
Java
rabbitmq
Messaging
AMQP
springamqp
AMQP 1.0 实现在哪里?等待还有意义吗?
我正在进行研究 以确定我们未来的产品应采用哪种消息传递解决方案 但我无法真正弄清楚这一点 有很多 AMQP 0 9 1 实现 RabbitMQ Apache Qpid OpenAMQ 等 但没有 AMQP 1 0 实现 尽管 1 0 已于
rabbitmq
AMQP
qpid
Rails 应用程序内的 AMQP 订阅者
是否可以使用我的 Rails 应用程序启动 AMQP 订阅者 可能通过初始化程序或其他东西 我想让它同时运行 也可以与 Rails 模型交互 下面是我的意思的伪代码示例 queue subscribe do msg body Foo cre
rubyonrails
rabbitmq
AMQP
JMS 和 AMQP - RabbitMQ
我试图了解什么是 JMS 以及它如何与 AMQP 术语相关联 我知道JMS是一个API AMQP是一个协议 这是我的假设 以及问题 RabbitMQ使用AMQP协议 而不是实现AMQP协议 Java客户端需要使用AMQP协议客户端库来连接
Java
JMS
rabbitmq
MessageQueue
AMQP
RabbitMQ:快速生产者和慢速消费者
我有一个应用程序 它使用 RabbitMQ 作为消息队列在两个组件 发送者和接收者 之间发送 接收消息 发送者以非常快的方式发送消息 接收方收到消息后会做一些非常耗时的工作 主要是数据量非常大的数据库写入 由于接收方需要很长时间才能完成任务
Java
Multithreading
rabbitmq
AMQP
producerconsumer
适用于 AMQP 的良好 Python 库 [关闭]
Closed 此问题正在寻求书籍 工具 软件库等的推荐 不满足堆栈溢出指南 help closed questions 目前不接受答案 您能推荐使用什么Python库来访问AMQP RabbitMQ 吗 根据我的研究pika似乎是首选之一
python
rabbitmq
AMQP
使用 RabbitMQ 的工作池和多租户队列
我开发的 Web 应用程序是一个基于多租户云的应用程序 很多客户端 每个客户端都有自己独立的 环境 但都在共享的硬件集上 我们正在引入用户批量处理的功能为后期处理工作 批处理工作的类型实际上并不重要 只是数量足够 没有工作队列就不太实际 我
rabbitmq
AMQP
worker
当 RabbitMQ 消费者崩溃时,获取的消息会发生什么情况?
如果我有一个 RabbitMQ 消费者批量检索 100 条消息 但在将这些消息标记为已处理之前它就崩溃了 那么这些消息是否丢失了 我希望队列中的每条消息至少被处理一次 处理在确认消息之前崩溃的消费者的推荐方法是什么 RabbitMQ 是否以
Queue
rabbitmq
MessageQueue
AMQP
Apache Camel AMQP - ActiveMQ AMQP 标头不匹配值 1,期望 0
我正在尝试创建一个通过 AMQP 与 ActiveMQ 集成的 Apache Camel 应用程序 我一直在按照提供的 骆驼示例 spring jms 项目 它通过标准 TCP 连接 但我已修改为使用我的独立 ActiveMQ 5 8 安装
apache
ActiveMQ
apachecamel
AMQP
qpid
如何在 spring-amqp 中设置消费者标签值
我正在尝试更新消费者标签 使其比随机生成的字符串提供更多信息 我们使用的模式包括主机名 标识符 随机字符串 这在我们的其他服务中工作得很好 即 NodeJS 和ampqlib 因为它们提供了一种传递该值的机制 但是 对于我们的 Java 服
Java
AMQP
springamqp
Spring RabbitTemplate 未使用 TTL 创建死信队列
我正在使用 spring rabbit1 1 和 RabbitMQ 3 3 1 我的 spring 配置将在 Rabbit MQ 上的 RabbitTemplate 的帮助下创建任何队列 但如果队列已配置 x dead letter exc
Spring
rabbitmq
AMQP
springamqp
springrabbit
主题交易所是唯一支持通配符的交易所吗?
在尝试理解直接交换 扇出交换和主题交换之间的区别时 我想确认主题交换的优点是生产者推送到交换并指定完全特定的路由键 并且队列可以通过以下方式绑定到多个路由键通配符 例如话题推向 channel gt basic publish msg lo
rabbitmq
AMQP
通过Java客户端连接Azure服务总线
我正在尝试使用 AMQP 协议从 Java 客户端连接 Azure 服务总线 我按照以下链接中的说明进行操作 http azure microsoft com en us documentation articles service bus
Java
Azure
JNDI
AMQP
azureservicebus
无法使用基于 JMS 的代码和 amqp 1.0 访问 ActiveMQ
我正在尝试使用 AMQP 1 0 连接到 ActiveMQ 代理 但我想在我的应用程序代码中使用 JMS 我对使用 JMS 感兴趣主要是因为我希望开发人员能够使用他们已经熟悉的 API 我在本地主机上运行 ActiveMQ 5 14 0 和
Java
ActiveMQ
AMQP
«
1
2
3
4
»