rabbitmq 相关问题

RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。

从RabbitMQ接收BizTalk

我是RabbitMQ的新手,但现在已经安装到Windows服务器上,并具有几个演示控制台应用程序(C#),它们可以很高兴地写入队列中的读取内容。以下代码用于提取消息...

回答 1 投票 0

有什么方法可以通过Spring Boot框架使用RabbitMQ来实现RPC?

生产者调用某些服务并从消费者那里得到响应(它具有所有逻辑)

回答 1 投票 -2

使用HAProxy作为RabbitMQ的负载均衡器不是最佳选择吗?

我正在为我的RabbitMQ集群找出最佳拓扑。我想要高可用性的队列。我在前面看到过很多关于将HAProxy用作循环负载均衡器的文章...

回答 1 投票 1

使用不同的交换类型动态创建队列

我正在尝试编写一种使用现有交换名称,新队列名称和路由键作为参数创建新队列的方法。交换的类型可能不同(直接,扇出,主题)。是...

回答 1 投票 0

降级RabbitMq的最安全方法

我们想将RabbitMq降级为较小的计划,但显然不想丢失数据或发生中断。我们在Heroku中使用RabbitMq,似乎找不到任何文档。好像我们...

回答 1 投票 0

Spring Cloud Stream RabbitMQ添加队列参数

我想知道如何向使用Spring Cloud Stream声明的rabbitmq队列添加额外的参数。我想对RabbitMQ 3.8.x使用单一活动使用者功能。为此,我必须添加一个...

回答 1 投票 0

具有复杂芹菜链的自动缩放芹菜工人

我正在尝试草拟自动缩放功能,以将其与具有复杂的基于链的工作流的芹菜一起使用。当前流:每6小时下载30份CSV,然后创建一个芹菜组来监视...

回答 1 投票 0

如何使用CLI从单个队列中删除所有消息?

如何使用cli从单个队列中删除所有邮件?我有队列名称,想要清除它。

回答 9 投票 138

Node.js amqplib何时关闭连接

我正在使用amqplib在我的node.js服务器中传输消息。我从RabbitMQ官方网站上看到了一个示例:var amqp = require('amqplib / callback_api'); amqp.connect('amqp:// localhost',function(...

回答 1 投票 6

从Windows服务访问新的RabbitMQ消息

我正在尝试使用Windows服务从RabbitMQ读取新消息,但不会触发接收新消息的事件。该服务可以在调试模式下作为控制台应用程序启动。在...

回答 1 投票 0

Symfony Messenger / RabbitMQ检测到被请求的消息

如果使用方消息失败,则默认情况下会延迟延迟重新排队消息。有没有一种方法可以在邮件中添加计数器,这样我就可以知道邮件是否在最后一次尝试中?这是所需的行为:...

回答 1 投票 0

Axon amqp消息传递,未触发事件处理程序

所以我正在开发我的第一个Axon应用程序。到目前为止,我使整个轴突项目都在整体中工作。之后,我开始使用Sprint Boot中的@Profile将应用程序划分为多个部分。...

回答 2 投票 1

如何确认消息已发送到RabbitMQ队列?

我将消息发送到RabbitMQ队列,但是使用者没有收到任何消息。 channel.assertQueue(config.amqp.queue显示{队列:“任务”,messageCount:0,consumerCount:1}消费者什么都不显示。...

回答 2 投票 0

无法启动RabbitMQ的插件

我是Windows和Rabbit MQ的新手,无法启动Web管理插件。我按照此处列出的步骤进行操作,但收到此消息。 PS C:\ Program Files \ RabbitMQ Server \ rabbitmq_server-3.8.0 \ sbin&...

回答 1 投票 1

Erlang机器立即停止(发行名称冲突?)。由于OnFail设置为忽略,因此服务不会重新启动

我正在使用RabbitMQ。由于某种原因,rabbitMQ服务一启动就停止。我在事件日志中看到以下错误:RabbitMQ:Erlang计算机立即停止(发行名称冲突?...

回答 5 投票 8

如何用Rabbitcq使用c发送和接收protobuf数据

我是rabbitmq和protobuf的新手,是否有一些代码示例可以用C语言通过Rabbitmq发送和接收protobuf数据?谢谢

回答 1 投票 -1

Rabbitmq消息到期

到期后邮件不会丢失。使用spring-rabbit java客户端,我正在发送带有设置为expiration:10000的标头的消息。供参考的是消息...

回答 1 投票 0

Spring cloud Rabbit配置尝试连接到本地主机5672

有很多例子,其中使用Java代码来配置纯兔子,但是与Spring Boot相关的文档是另一回事。我的要求很基本-单个队列,单个...

回答 2 投票 0

vhost损坏时保持队列和交换

我们最近在使用RabbitMQ时遇到了一个问题:当服务器的硬盘驱动器已满时,RabbitMQ的虚拟主机已损坏,无法使用。唯一使RabbitMQ再次起作用的函数...

回答 1 投票 0

RabbitTransactionManager无法在ChainedTransactionManager上提交事务

我正在尝试为Rabbit和Kafka使用一个事务管理器。首先,我从Rabbit回调中获取一条消息,然后将其发送给Kafka主题。但是我总是得到一个异常,表明Rabbit ...

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.