amqp 相关问题

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

amqp-cpp 库:channel->cancel(consumerTag) 似乎没有取消

我正在使用 AMQP-CPP 库(不是 amqp C 库)连接到 RabbitMQ。消费队列是有效的,发布也是如此。我不使用交换器或任何东西,只是一个队列上的一个消费者。当

回答 1 投票 0

无法使用 AMQP 0.9.1 客户端连接到 ActiveMQ Artemis

我正在尝试使用 AMQP 0.9.1 Go 客户端连接到 ActiveMQ Artemis 代理,但有一些问题我无法解决。 这是我的客户端代码: 包主 进口 ( “fmt”...

回答 2 投票 0

无法使用 AMQP 连接到 ActiveMQ Artemis

我正在尝试使用 AMQP 客户端连接到 ActiveMQ Artemis 代理,但有一些问题我无法解决。 这是我的客户端代码: 包主 进口 ( “FMMT” &quo...

回答 2 投票 0

无法使用 AMQP 连接到 Artemis

我正在尝试将 Artemis 代理与 amqp 客户端连接。但有一些问题我无法弄清楚。 这是我的客户端代码: 包主 进口 ( “FMMT” “日志” &...

回答 1 投票 0

在向 Azure 队列发送消息时,面临连接被对等方重置、errorContext[NAMESPACE: <Namespace>]

我正在尝试使用 ClientSecretCredential 将消息发送到 Azure 服务总线上的队列。使用 AzureSDK 代码时出现错误。下面给出了代码和错误跟踪。最新的罐子...

回答 1 投票 0

RabbitMQ sendtoQueue 并在同一个 REST API 调用中消费

我正在使用 2 个快速微服务,第一个(产品)负责产品队列,第二个(出价)负责出价队列。通道和连接是在服务器自行启动时建立的...

回答 1 投票 0

如何在SpringBoot AMQP中动态生成消息队列并使用PK值绑定键

我想实现一个功能,属于特定群组的用户可以在群组内发布内容,并且该群组的所有成员都会收到通知。 为了实现这个目标,我研究了 AMQP...

回答 0 投票 0

如何在 TTL 后向 DLX 发送未确认的消息?

我有兔子队列 my_queue,它配置有 DLX 向 my_queue_dlx 发送消息。使用 message-ttl 的测试按预期工作。一条消息保留在 ttl 队列中,后来移动到 DL...

回答 1 投票 0

如何测试与RabbitMQ Server的连接?

我有以下问题: 我需要测试与运行在 AMQ 协议上的 RabbitMQ 服务器的连接,我需要使用 CMD 或类似的东西来完成它,所以我可以从 scr 执行命令...

回答 2 投票 0

ActiveMQ 传输协议:amqps 与 ampq+ssl

我尝试通过 amqp 协议使用来自 ActiveMQ 服务器的消息。由于 ActiveMQ 以及从 javax.jms 到 jakarta.jms 的切换以及与 Spring-Boot v3 的分离

回答 0 投票 0

RabbitMQ Exception: operation queue.declare caused a channel exception not_found in server side

我定义了两个队列“request.queue”和“result.queue”,我的 Web UI 在“request.queue”中生成消息,然后我的 python 应用程序从“request.queue”中使用它并开始处理,然后推

回答 1 投票 0

Symfony AMQP 重试成功...?

我目前在站点和 API 之间进行通信,当我向该 API 发出请求时,AMQP 启动请求并接收响应,但是,它在收到请求后重试请求 3 次

回答 0 投票 0

Rabbit Mq 在第一条消息后不使用消息

在队列中发布消息后,在监听端收到两次相同的消息。 在接收到第一条消息后,监听器停止进一步消费消息。在我重新启动侦听器应用程序后...

回答 1 投票 0

监听一个空的rmq队列网络密集吗?

在微服务系统中,我有两个服务:service1 有一段数据,service2 需要不时更新数据。为了获取状态,service2 调用服务 1

回答 2 投票 0

AMQP Qpid ActiveMQ 路由密钥

我正在使用 ActiveMQ“Classic”,我想使用 AMQP 协议。 目前,我正在尝试使用 AMQP 1.0 和 Java 客户端 Qpid JMS 客户端 2.2.0 和 qpid-amqp-1-0-client-jms 0.32 ...

回答 1 投票 0

AMQP 消息未被消费

我是 AMQP 的初学者,我在将消息从发布者发送到消费者时遇到了问题。我正在使用 rabbitmq。发布者似乎正在发布请求,然而,re...

回答 0 投票 0

验证 LavinMQ 版本

我最近一直在探索 AMQP 消息代理 LavinMQ。 我目前正在尝试弄清楚我的服务器上运行的代理版本。 是否有用于此的 CLI 命令?也许一些...

回答 1 投票 0

更新后无 AMQP 连接

今晚 plesk 服务更新了我的 Rabbitmq 服务器版本 3.11.12-1(旧版本 3.11.11-1)。 现在我遇到了远程 AMQP 连接的问题。服务器拒绝所有连接尝试。 202...

回答 0 投票 0

在不同线程中运行的函数之间传递函数(回调)变量

我正在尝试开发一个使用 pika 和线程模块的 Python 3.6 脚本。 我有一个问题,我认为是由于我的 A) 对 Python 和编码很陌生,B) 我不是

回答 1 投票 0

如何使用相同的@Incoming 方法并行处理多个 AMQP 消息

是否可以使用带有 quarkus 和 smallrye-reactive-messaging 的 @Incoming("queue") 注释的相同方法并行处理多个 amqp - 消息? 更准确地说,我...

回答 3 投票 0

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