rabbitmq 相关问题

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

如何为通过 AddConsumer() 创建的队列配置 PurgeOnStartup？

防止 XY 问题的一些背景：我正在开发一个系统，其中每 X 分钟发送一条消息以在服务中的 Pod 上运行作业。当所有 pod 都不健康或重新启动时，这些

c# rabbitmq masstransit

回答 1 投票 0

Django model.save() 执行不一致的更新

我正在 RabbitMQ 消费者的回调函数中使用 django ORM 与 MySQL 数据库进行通信。这些消费者在单独的线程上运行，并且每个消费者都建立了......

python django django-rest-framework rabbitmq python-multithreading

回答 1 投票 0

运行“rabbitmq-plugins启用rabbitmq_management”..失败

首先安装二郎兔子MQ服务器然后，尝试运行命令来启用插件，如下所示： C:\Program Files (x86)\RabbitMQ 服务器 abbitmq_server-3.6.9\sbin>rabbitmq-plugins 启用

plugins rabbitmq

回答 3 投票 0

无法连接Spring AMQP / Rabbit MQ：org.springframework.amqp.AmqpConnectException：java.net.ConnectException：连接被拒绝：connect

我是 Spring AMQP / Rabbit MQ 的新手。我在我的项目中使用 Spring AMQP / Rabbit MQ。运行tomcat后遇到以下错误： org.springframework.amqp.rabbit.listener.

rabbitmq spring-amqp spring-rabbit

回答 6 投票 0

带有 RabbitMQ 崩溃的 Docker 容器

首先，这似乎是一个与此处发布的类似问题：Droping container with RabbitMQ in Docker 然而，几天后该线程似乎不活跃，我很想向...

docker docker-compose rabbitmq

回答 3 投票 0

如何将来自 RabbitMQ 代理的“byte[]”数据转换为 Ballerina 中的记录类型

我在 ballerina 包中使用 RabbitMQ 模块以及服务器和客户端。在客户端中，我收到的内容为 byte[]，需要在...之前转换为 CustomerDetails 记录类型

rabbitmq ballerina ballerina-swan-lake

回答 1 投票 0

Spring Boot RabbitMQ 尝试反序列化未经授权的类异常

我在 Spring Boot 项目中使用 RabbitMQ：发件人 @成分 @AllArgsConstructor 公共类 UserSender { 私人最终 RabbitTemplaterabbitTemplate; 公共字符串发送（）{ 用户你...

rabbitmq amqp

回答 1 投票 0

SpringBoot RabbitMQ 尝试反序列化未授权类异常

我在Springboot项目中使用RabbitMQ：发件人 @成分 @AllArgsConstructor 公共类 UserSender { 私人最终 RabbitTemplaterabbitTemplate; 公共字符串发送（）{ 使用我们...

rabbitmq amqp

回答 1 投票 0

RabbitMQ 和 GCP Pub/Sub 集成

我正在致力于集成 RabbitMQ 和 GCP Pub/Sub。我正在使用 Pika 库和 Python。连接是通过BlockingConnection 建立的。我的消费者作为单独的线程运行。最大预期

google-cloud-platform rabbitmq google-cloud-pubsub pika

回答 1 投票 0

如何在MassTransit中制作过滤器？

我正在尝试处理 MassTransit，我有许多带有 StableDefussion 的服务器，它们接受在队列中生成图像的任务但事实是不同的服务器有不同的...

c# rabbitmq masstransit

回答 1 投票 0

Azure Fuction 应用程序 RabbitMQTrigger AES 加密消息未正确解密。有效负载似乎不是 Base64 字符串

抱歉，但我对解密 aes 消息和 RabbitMQ 还很陌生。我有一个带有以下 RabbitMQ 触发器的 azure 函数应用程序：代码： [FunctionName("RabbitMQTriggerTest")]

c# encryption azure-functions rabbitmq aes

回答 1 投票 0

在 TestSuite 中模拟 AMQPTemplate

我正在将 JUnits 作为 TestSuite 运行。 JUnit 类之一用于测试将消息发布到 RabbitMQ 的代码。我应该模拟代码以将消息发布到 MQ。怎么会...

rabbitmq spring-amqp spring-rabbit

回答 1 投票 0

Quarkus 反应式消息传递rabbitmq 连接器，具有客户端证书身份验证

我想使用 Quarkus RabbitMQ 连接器连接到 RabbitMQ Broker（队列）。客户需要同行验证和客户端证书身份验证（而不是用户名/密码...

java rabbitmq quarkus quarkus-reactive

回答 1 投票 0

Spring Cloud Stream Rabbit Binder 并发

我有一个消费者微服务，用于处理来自其他生产者微服务的消息。我使用 Spring Cloud Stream 和 RabbitMq Binder 管理事件驱动结构。我想限制最大浓度...

java spring-boot rabbitmq spring-cloud-stream

回答 1 投票 0

Spring amqp RetryCache 抛出 AmqpRejectAndDontRequeueException 时未清除

我有一个简单的 Rabbit 侦听器，它总是抛出 AmqpRejectAndDontRequeueException （以测试侦听器是否可以处理多个无效消息）。配置是： @RabbitListener( id = 测试配置。

java rabbitmq spring-amqp spring-rabbit spring-retry

回答 1 投票 0

k8s 内部网络似乎堵塞了

有一个 k8s 安装，除了许多其他安装之外，还托管两个 pod：一个微服务和一个 RMQ 实例。我还可以在本地计算机上运行微服务，微服务从中进行对话......

kubernetes networking rabbitmq

回答 1 投票 0

“无法加载模块E:\.....“，但是我已经将环境变量ERLANG_HOME配置为D:...，

我想在Windows 10上安装RabbitMQ。我按照官方手册告诉我必须先安装erlang。我下载了 erlang 并配置了位于 D 的环境变量...

rabbitmq erlang

回答 1 投票 0

通过 RabbitMQ 取消 Rust 中长时间运行的 Rayon 任务的策略 [已关闭]

我正在用 Rust 开发一个执行器来处理计算密集型任务，作为大型 Web 应用程序的一部分。执行器从 RabbitMQ（使用 lapin）接收作业并处理各种 CPU 密集型操作...

rust rabbitmq rust-tokio rayon

回答 1 投票 0

使用 RabbitMQ 死信队列消息

我已经阅读了 RabbitMQ 及其处理消费者无法处理的事件的技术（未确认的消息、过期的 ttl-s 等）。 RabbitMQ DLX 这是工作方式（正如我

c# .net rabbitmq event-bus

回答 2 投票 0

RabbitMQ 连接错误“没有指定的端点可访问”

我在服务器和我的系统上安装了rabbitmq服务。我想使用 RPC 模式： var 工厂 = 新的 ConnectionFactory() { 主机名 = "158.2.14.42", 端口 = Protocols.DefaultProtocol.

c# asp.net rabbitmq

回答 13 投票 0

rabbitmq 相关问题

最新问题