amqp 相关问题

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

Azure 事件中心连接已关闭错误

我在使用 azure 事件中心发送事件消息时看到类似以下错误。但正如我在天蓝色门户中看到的那样,指标显示事件消息已发送到事件中心。所以我

回答 1 投票 0

如何使用 KEDA 查看来自 RabbitMQ 的未确认消息?

我创建了一个 ScaledObject,它根据 RabbitMQ 队列中存在的请求数量来扩展 Celery 工作单元。这是在 Azure Kubernetes 服务集群中。 我使用了以下网址...

回答 1 投票 0

RabbitMQ 队列消息

在rabbitMQ Web界面的队列选项卡上,我看到“概述”面板,我在其中找到了这些: 排队的消息: 准备好 未确认 全部的 我猜“总计”消息是什么。但什么是“Rea...

回答 2 投票 0

RabbitMQ:如果消费者永远消失,则删除队列?

想象每个用户都有自己的队列。当用户离线时,消息被放入队列中,当他们重新连接时,他们会收到所有这些消息。 但是,如果客户离开后再也没有

回答 3 投票 0

Python QPID Proton 容器阻止代码执行

我有一个 Python 3.9 项目,我想在其中运行一个连接到 AMQP 1.0 代理并侦听传入消息的服务。相同的服务还应该提供 RESTful API 以便触发

回答 1 投票 0

用于 AMQP 的优秀 Python 库 [已关闭]

您能推荐使用什么Python库来访问AMQP(RabbitMQ)吗?根据我的研究,鼠兔似乎是首选。

回答 4 投票 0

我正在尝试使用Log4j2的Rabbit Appender,但我的程序报告错误

我的Log4j2.xml 我的Log4j2.xml <Console name="STDOUT" target="SYSTEM_OUT"> <PatternLayout pattern="%d %-5p %C{2} - %m%n"/> </Console> <RabbitMQ name="rabbitmq" virtualHost="/" exchange="" exchangeType="direct" declareExchange="true" durable="true" autoDelete="false" host="127.0.0.1" port="5672" user="admin" password="1234" applicationId="myAppId" routingKeyPattern="%X{applicationId}.%c.%p" contentType="text/plain" contentEncoding="UTF-8" generateId="true" deliveryMode="NON_PERSISTENT" charset="UTF-8" senderPoolSize="3" maxSenderRetries="5"> <PatternLayout pattern="${LOG_PATTERN}"/> </RabbitMQ> 当我的程序启动时,我收到这样的错误 ERROR Error processing element RabbitMQ ([Appenders: null]): CLASS_NOT_FOUND ERROR Unable to locate appender "rabbitmq" for logger config "root" 我猜我可能缺少一些依赖项 希望有人能帮助我,谢谢 老兄,我遇到了几乎同样的问题,你解决了吗?

回答 1 投票 0

使用 springboot 的 Rabbitmq RPC(请求-回复)

我想使用 RabbitMQ 实现微服务通信的请求-回复模式。然而,问题是每个内部调用都会创建一个新队列,并且默认情况下,队列大小在

回答 1 投票 0

如何配置 ActiveMQ Artemis 服务器以跨不同协议 AMQP 和 Openwire 互操作消息

我有一个 ActiveMQ Artemis 服务器,配置如下: 公共静态无效 updateConfig(配置配置){ 尝试 { config.setPersistenceEnabled(假) .

回答 1 投票 0

RabbitMQ 创建多个连接

这是生产者代码: 从“amqplib”导入*作为amqp; 导出默认类 Producer { 渠道; 异步创建频道(){ const 连接 = 等待 amqp.connect("...

回答 1 投票 0

如何配置ActiveMQ Artemis以通过Java使用AMQP 1.0和其他协议

我有一个运行良好的 ActiveMQ Artemis 服务器。我现在想在服务器上为使用 pub-sub 的节点应用程序启用 AMQP。虽然我的节点 pub sub 能够连接到它,但它们都不能连接

回答 1 投票 0

如何配置 Artemis ActiveMQ 以使用 AMQP 1.0 和其他 Java 协议

我有一个工作正常的 artemis 服务器。我现在想在服务器上为使用 pub-sub 的节点应用程序启用 AMQP。虽然我的节点 pub sub 能够连接到它,但它们既不发布也不发布

回答 1 投票 0

单个队列,多个@RabbitListener但服务不同

是否可以有一个@RabbitListener,例如: @RabbitListener(队列= STORAGE_REQUEST_QUEUE_NAME) 公共 FindApplicationByIdResponse findApplicationById(FindApplicationByIdRequest 请求...

回答 1 投票 0

在 Wildfly 内置 Artemis ActiveMQ 服务器中使用 AMQP 客户端时出现异常 javax/management/openmbean/CompositeData

我已经在 Wildfly 23.0.1 中使用 QPID C++ 客户端 (AMQP) 一段时间了,没有任何问题。 现在我想使用更新版本的Wildfly(30+)并发现一个主要问题:QPID客户端是......

回答 1 投票 0

Azure 服务总线:Amqp 空闲超时条件 = amqp:link:detach-forced

我得到的错误: 2019-12-09 06:39:33.189 错误 107132 --- [http-nio-8082-exec-5] o.a.c.c.C.[.[.[/].[dispatcherServlet] : servlet [dispatcherServlet] 的 Servlet.service()带有路径 [] 的上下文...

回答 3 投票 0

芹菜和定制消费者

据我所知,Celery 既充当消息的生产者又充当消息的消费者。这不是我想要达到的目标。我希望 Celery 仅充当消费者,根据消息触发某些任务...

回答 4 投票 0

如何使用php-amqplib连接ActiveMQ Classic Docker镜像

我正在尝试创建一个自定义命令,该命令应该使用来自 ActiveMQ Classic 队列的消息。我正在使用 php-amqplib,并且创建了自定义连接器和 ActiveMQServiceProvider。我越来越

回答 1 投票 0

RabbitMQ:多个消费者的循环

项目主要由三部分组成: 生产者(设备)通过 MQTT 协议向 Broker 发送数据 RabbitMQ 代理 用于应用程序和代理之间通信的消费者(spring AMQP)。 (设备 MQTT

回答 1 投票 0

Celery 未接收在后台运行的任务

我在设置 celery 与我的 Flask 应用程序一起使用时遇到问题。我使用了准系统应用程序来测试配置,发现我的 celery 工作程序已启动,但没有获取任何任务...

回答 2 投票 0

Kafka 中的 AMQP 主题等效

我有一个解决方案,它使用消息传递系统(QPID)在应用程序之间传递消息。 一个应用程序从外部服务器接收大量实时信息,涉及数千个

回答 1 投票 0

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