rabbitmq 相关问题

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

无法发布我的消息，出现反序列化未经授权的类错误

我正在尝试使用 RabbitMq 创建消息队列。当我尝试将消息推送到队列时，出现以下错误消息 org.springframework.amqp.rabbit.support.ListenerExecutionFailedException：

rabbitmq spring-jms spring-rabbit rabbitmq-exchange rabbitmqctl

回答 2 投票 0

Spring Boot RabbitMQ RabbitListener ListenerExecutionFailedException

org.springframework.amqp.rabbit.support.ListenerExecutionFailedException：无法转换消息在 org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage(

spring spring-boot rabbitmq spring-rabbit

回答 2 投票 0

为什么celeryworker无法使用docker compose连接到rabbitmq

我正在尝试使用 docker compose 组合我的服务，但我的 celery 和 celerybeat 服务无法与我的rabbitmq 服务连接。这是 docker-compose.yml 文件中我的rabbitmq服务拉布...

docker docker-compose rabbitmq celery celerybeat

回答 2 投票 0

在RabbitMQ中，如何从所有_error队列中获取所有错误消息

我被要求获取所有 RabbitMQ _error 队列中所有异常的列表。我可以使用管理站点从每个 _error 队列中复制和粘贴。但是有没有办法从命令行...

rabbitmq

回答 1 投票 0

RabbitMQ MassTransit 批量竞争消费者

我已经设置了事件ExampleEvent的批量使用者，并将其设置为ConcurrencyLimit = 16、MessageLimit = 100、TimeLimit = 5秒并按ExampleEvent.GroupingKey字段分组。这很好用...

rabbitmq masstransit

回答 2 投票 0

错误：主机“172.27.0.5”没有 pg_hba.conf 条目，什么？

我有一个错误困扰了我好几天，当我尝试编译我的auth（rabbitmq）和我的hyper（api网关）时，我的api有点工作，我需要下载一些包，但我的auth给出了Postg ...

node.js postgresql rabbitmq nestjs

回答 1 投票 0

使用供应商为 RabbitMq 生成消息

我需要轮询消息并将其发布到 RabbitMQ。设置了100个store，每个store可以轮询5条以上消息并将其发布到RabbitMQ。每分钟进行一次轮询。下面是

rabbitmq spring-cloud spring-cloud-stream spring-cloud-stream-binder

回答 1 投票 0

NestJS RabbitMQ @golevelup/nestjs-rabbitmq 如何模拟服务调用来发布

我有一个使用 @golevelup/nestjs-rabbitmq 模块的工作发布/订阅实现。我想编写一个服务规范来测试 MessagingService 的发布方法，该方法调用 AmqpConne...

testing jestjs rabbitmq nestjs

回答 1 投票 0

RabbitMQ：多个消费者的循环

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

rabbitmq amqp spring-amqp spring-rabbit round-robin

回答 1 投票 0

向所有应用程序实例广播事件

在其中一个应用程序中，正在使用内存缓存，考虑到该应用程序有多个实例正在运行，是否有办法刷新/更新相同的内容。使用集中式缓存...

python java redis rabbitmq software-design

回答 1 投票 0

rabbitmq：在预检查阶段检查每个rabbit主机名是否唯一解析为正确的IP地址

我尝试按照此链接在运行 CentOS 8.3.2011 的虚拟机上部署 OpenStack，但在运行命令时在预检查阶段出现错误： kolla-ansible -i ./一体化

ansible rabbitmq virtual-machine openstack

回答 3 投票 0

RabbitMQ 将有效负载铲入 ActiveMQ Classic 的消息格式问题

我有一个设置，其中 RabbitMQ 中的队列通过 AMQP (1.0) 将数据铲到 ActiveMQ Clasic 6.0.1 中的队列。从 RabbitMQ 发布以下数据（JSON）时 {“你好”：“世界&q...

rabbitmq activemq rabbitmq-shovel

回答 1 投票 0

Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection::ack()：返回值必须是bool类型，返回null

我在处理消息时遇到此错误，问题出在哪里？它在重新启动之前有效。我可以连接到兔子。我没有改变任何东西，作曲家使用该作曲家配置进行更新。排队停止工作...

symfony rabbitmq symfony-messenger

回答 1 投票 0

Celery Beat 无法连接到 Rabbitmq 容器

我的 celery Beat docker 容器（据我认为）连接消息代理时出现问题。我有一个正在运行的 RabbitMQ 容器： .... 兔子MQ：图片：rabbitmq:3.11.13-management-alpine

django docker docker-compose rabbitmq celery

回答 1 投票 0

如何重启SimpleMessageListenerContainer

我尝试使用 Spring Boot 连接到 RabbitMQ。连接应始终重新启动/重试连接。我在发生致命异常后重新连接时遇到问题。应用程序永远不会丢失

java spring-boot rabbitmq spring-integration spring-rabbit

回答 2 投票 0

连接到docker容器内的rabbitmq时出现问题

我正在编写一个简单的应用程序来测试与rabbitmq的使用。这是代码：包主进口（ “日志” “时间” “github.com/streadway/amqp” ）功能

docker go rabbitmq

回答 1 投票 0

Spring Integration MQTT 共享订阅

我的项目需要支持mqtt。我使用 RabbitMQ 作为代理。我开发了 Spring Boot 应用程序，并使用 Spring Integration MQTT。 @配置公共类 MqttConfig { @豆公开

spring spring-boot rabbitmq mqtt spring-integration-mqtt

回答 1 投票 0

如何使用 updateUser(rabbitmq) 哈希新传递的密码？

好吧，我可以在 createUser 中对我的密码进行哈希处理，但是，要更新用户，我需要对这个新传递的密码进行哈希处理，但是当我有 data.senha: senhaHasheada 或 usuarioachar.senha: senhaHasheada 时，我可以...

node.js rabbitmq nestjs

回答 1 投票 0

使用bitnami/rabbitmq图表从github安装额外的rabbitmq插件

目标：为bitnami提供的rabbitmq图表准备一个values.yaml文件，以便插件rabbitmq-message-deduplication在运行helm install后准备就绪并可用... 以前的解决方案...

kubernetes rabbitmq kubernetes-helm bitnami

回答 2 投票 0

如何配置消费者生成的错误队列以使用与正常队列相同的路由键？

假设我有一个消费者：公共类 TestConsumer : IConsumer { ... 配置为使用路由密钥： cfg.ReceiveEndpoint("test_queue", e=> {...

c# rabbitmq masstransit

回答 1 投票 0

rabbitmq 相关问题

最新问题