rabbitmq 相关问题

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

CachingConnectionFactory确认类型简单与相关。

CachingConnectionFactory确认类型简单与相关的区别是什么。

回答 1 投票 0

Masstransit RabbitMQ发布者未能发布 "正确 "的合同。

我一直在使用Masstransit和RabbitMQ创建消息合同以实现两个.NET核心Web API之间的通信,我已经玩了一段时间,我偶然发现了以下内容。...

回答 1 投票 0

正运,返回消耗的信息。

我对Masstransit是个新手,我不太清楚如何配置这个。有没有办法将消耗的消息返回到我调用Consume方法的地方?Consume方法返回...

回答 1 投票 0

使用Spring上下文进行的集成测试无法接收RabbitMQ消息。

RabbitMQ MessageConsumer没有收到发布的消息 我正在编写一个集成测试,它应该从队列中接收消息并进行处理。但消费者根本没有......

回答 1 投票 0

无法在安装stablerabbitmq-ha时从发布清单中构建kubernetes对象。

当我试图安装 "rabbitmq-ha "时,出现了一个错误 $ helm install rabbitmq stablerabbitmq-ha Error: unable to build kubernetes objects from release manifest: unable to recognize "": no matches for ...

回答 1 投票 0

RabbitTemplate: 经纪人不支持通过'amq.rabbitmq.reply-to'快速回复。

为什么RabbitTemplate不能使用direct-reply? 是否有任何与broker有关的配置?

回答 1 投票 0

Masstransit - Rabbit MQ虚拟主机。

string uri1 = @"rabbitmq:/myusername:mypassword@myipmyvirtualhostmyqueue"; 我一直得到一个ConfigurationException was unhandled. ...

回答 1 投票 2

如何在 REST 客户端和 (Python) REST 服务器之间插入 RabbitMQ?

如果我开发了一个托管在Apache中的REST服务和一个Python插件,它的服务是GET、PUT、DELETE、PATCH;而这个服务是由Angular客户端(或其他REST交互浏览器技术)消费的......

回答 1 投票 0

MassTransit消费者从未收到信息

我正在按照在ASP.NET Core应用程序中使用RabbitMQ和Autofac的MassTransit的文档构建一个演示应用程序。我的程序代码: namespace MessageDemo { public ...

回答 1 投票 0

如何在rabbitMq中检查消息是否已经提前发送?

我有一个rabitmq服务器运行,它有一个队列。我在队列中发布一些数据。现在,如果有一些错误处理该消息在那个时候,然后我拒绝它为ch.reject(msg,true)。所以消息是...

回答 1 投票 0

像这样的Java "实例过滤"[RabbitMQ]处理消息的最Pythonic方式是什么?

从Java背景出发,当开发由JMS连接的服务时,我曾经处理消息并通过检查它们的类型来区分它们,例如(简化的)。Object object = myQueue.consume();...

回答 1 投票 0

RabbitMQ消费者:已关闭异常。

我有一个简单的RabbitMQ发布者和消费者代码,如下所示。首先,我在My_Tasks队列中创建了10条不同数量的消息。当我试图获取这些消息时,一个接一个,并使用autoAck标志......。

回答 1 投票 0

如何在spring api项目中设计RabbitMQ的实现?

这将是一个声明性的问题。我知道什么是rabbitMQ,为什么要用它。我有一个spring API项目,有很多API端点。例如,localhost:80do-A,localhost:80do-B......。

回答 1 投票 1

rabbitmq一个队列中的多个消费者--只有一个人得到消息。

我实现了多个消费者,他们从一个队列中获取消息,我使用类似于这个例子的东西来做这件事,除了我在一个无限循环上做basic.get ...

回答 1 投票 8

如何在 REST 客户端和 (Python) REST 服务器之间插入 RabbitMQ?

如果我开发了一个托管在Apache中的REST服务和一个Python插件,它的服务是GET、PUT、DELETE、PATCH;而这个服务是由Angular客户端(或其他REST交互浏览器技术)消费的......

回答 1 投票 0

是否可以在云运行服务中暴露5001(HTTP)和5672(TCP)端口?

我正在Google Cloud中建立一个解决方案。我需要一个 RabbitMQ 队列代理和一个用 .NET Core 2.2 开发的 WebAPI。其想法是让 WebAPI 连接到 RabbitMQ 以接收消息。我有...

回答 1 投票 0

RabbitMq和nodeJs的集成 当队列中到达2条相互关联的消息时,对订阅者进行调用的功能。

我有2个微服务,它们正在异步处理一些输入的数据(通过队列ABC提供)。

回答 1 投票 2

DirectMessageListenerContainer可以和BatchMessageListener一起使用。

在当前版本org.springframework.amqp: 2.2.2 BatchMessageListener中包含。@Override default void onMessage(Message message) { throw new UnsupportedOperationException("不应该被...容器调用"); @Override default void onMessage(Message message) { throw new UnsupportedOperationException("不应该被...

回答 1 投票 0

磁盘满了会导致linux中的网络问题吗?

我在Linux机器上运行RabbitMQ服务器,当我的磁盘变成半满时,我无法再向我的rabbitMQ服务器发出任何连接请求,当我清理磁盘时,问题得到了解决。

回答 1 投票 -1

| Celery

In production server, I am getting the following error in celery console which never happened before. I found the same issue in other posts, they are saying give valid url but the url i have given in ...

回答 1 投票 0

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