amqp 相关问题

AMQP是一种开放式消息传递标准。它为高性能企业消息传递定义了线级协议和语义框架。如果您正在使用特定代理(例如:[rabbitmq]),则AMQP标记可能是多余的。 AMQP不应与Apache [ActiveMQ]混淆

ActiveMQ:具有选择器的STOMP和AMQP客户端

是否可以同时将STOMP客户端和AMQP客户端与ActiveMQ一起使用,并在消息上使用选择器?即我可以在AMQP客户端的消息头中放入一些数据并使用此特定的...

回答 1 投票 0

如何在IBM mq amqp中使用phpamqplib

我正在尝试使用phpamqplib或pecl amqp将消息发送到IBM MQ槽amqp协议。使用phpamqplib,我得到:3/21/20 19:04:28.965 AMQXR0021W:网络地址'......'上的客户端'null'...

回答 1 投票 0

在RabbitMQ中获取当前未确认的消费者消息

我正在尝试正常关闭正在消耗RabbitMQ消息的进程。我知道我可以使用Channel.cancel阻止RabbitMQ向该进程发送任何新消息,但是我需要...

回答 1 投票 0

为什么我不能填写AMQP-CPP示例代码?

我正在尝试从AMQP-CPP自述文件AMQP-CPP编译一些示例代码。但是由于某种原因,我无法编译为TcpConnection给出的示例。一切看起来都很好,但是我...

回答 2 投票 0

根据RabbitMQ中的邮件正文属性有选择地使用邮件

假设我有一种情况,我需要等待1分钟才能执行某些操作。如果已过期,请尝试其他操作。我当前的解决方案建议基于RabbitMQ ...

回答 1 投票 0

NodeJS rhea AMQP客户端的故障转移

我在计算机上运行了多个ActiveMQ实例。它们被配置为共享文件系统主从。如果一台ActiveMQ服务器已关闭,则另一台应自动启动。 ...

回答 1 投票 0

RabbitMQ:查找由于使用者异常而导致频道关闭的原因

我有一个使用RabbitMQ Java客户端库创建的RPC服务器,使用消息时收到以下错误:com.rabbitmq.client.ShutdownSignalException:清除通道关闭; ...

回答 1 投票 1

带有Vue JS的RabbitMq

我尝试使用rabbitMq消耗来自前端的消息,我已经有了rabbitMq并带有数据队列(AMQP)。我搜索了RabbitMq中的Vue-J或JavaScript,但是没有找到任何有用的信息。 ...

回答 1 投票 0

事件中心中的活动连接

我正在尝试找出显示为事件中心活动连接的Azure指标的一部分的数字。有人对此有更多细节吗?这是我的情况-我们有一个使用EventHub ...的Web API ...

回答 1 投票 0

SimpleMessageListenerContainer无法正确调用消息处理程序

我正在尝试在Spring Boot应用程序中监听RabbitMq队列。在我的RabbitConfig.java文件中,我有以下bean:// RabbitConfig.java // ...排队,交换,绑定bean等@Bean ...

回答 1 投票 0

将无代理AMQP写入MQTT适配器

我想实现一个从amqp到mqtt的适配器,它将接收amqp消息,获取其有效负载并将其作为mqtt消息发布到我的mqtt代理。因此,适配器必须能够在...

回答 1 投票 0

RabbitMQ-在删除队列之前移动消息

使用RabbitMQ 3.7.16,带有spring-amqp 2.2.3版本。多个客户端将消息发布到我们RabbitMQ服务器中的主题交换。为了分别按...

回答 1 投票 1

RabbitMQ-如何通过多个通道重用同一连接

我正在尝试掌握RabbitMQ的一些最佳做法。我的目标是创建单个连接,然后在该单个连接上使用,在此连接上创建多个通道。跟随...

回答 1 投票 0

Google-cloud-PubSub是否支持amqp 1.0协议?

我找不到与上述问题有关的任何参考文献。有没有人试图在Google Cloud的Pub / Sub中使用amqp 1.0?它甚至受支持还是应该用作独立的...

回答 1 投票 0

如何从在本地docker容器中运行的Rabbitmq队列中读取消息

我正在docker容器中的本地mac中运行Rabbitmq。我通过浏览器中的GUI(端口15672)访问了它,并创建了一个队列,交换并在该队列中发布了一些消息。我正在尝试...

回答 1 投票 0

缺少客户端的心跳,超时:30秒-RabbitMQ

我正在使用Rabbitmq进行发布/订阅。我有两个通过rabbitmq交换相互通信的微服务。微服务1发布一些数据,微服务2使用它。 ...

回答 1 投票 3

RabbitMQ节点JS验证用户ID

我使用RabbitMQ,SocketIO和MongoDB为我的应用创建私人消息。计划是当新用户注册时,应用程序为该用户创建新的唯一RabbitMQ队列,使该用户能够获取消息...

回答 1 投票 0

使用Apache.NMS.AMQP从.NET连接到AmazonMQ(ActiveMQ)代理

我无法使用Apache.NMS.AMQP客户端(GitHub存储库)连接到我的AmazonMQ代理。我已启动并运行AmazonMQ代理,并且可以连接到代理控制台。在我的.NET项目中,我有...

回答 1 投票 1

RabbitMQ vs Socket.io?

我正在实时进行实时网络应用开发。浏览器用户应该能够通过node.js服务器相互通信。其中一位用户编写了一条消息,其他所有用户都将收到该消息。我...

回答 3 投票 54

动态队列和侦听器,消息未发送?

兔子配置:包com.rabbitMQ;导入org.slf4j.Logger;导入org.slf4j.LoggerFactory;导入org.springframework.amqp.core.AmqpAdmin;导入org.springframework.amqp.core.AmqpTemplate; ...

回答 1 投票 0

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