RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。
如何在Spring引导API中实现RabbitMQ使用者部分(接收者)
我将把我的DATA发送到RabbitMq生产者(消息发送者)并从RabbitMq消费者(消息接收者)获取负责任的数据。生产者部分工作正常。现在我的问题是如何实现...
已经在Windows核心2016 Server中安装了Elasticsearch-6.6.0和kibana-6.6.0,它已经启动并运行,我不得不从Rabbitmq索引数据,所以下载并解压缩了logstash-6.0.0并进行了配置...
我正在通过命令运行花:芹菜花--broker = amqp:// : @localhost:5672 / --broker_api = HTTP:// : @ ...
我正在使用node-celery github链接来实现芹菜芹菜和rabbitmq的第一步。就像在芹菜中我们定义任务然后我们推动它们。我在tasks.py中定义的任务是......
我想做什么我尝试创建rabbit-mq发布者和订阅者。它按预期工作,直到我尝试重新启动我的rabbit-mq服务器。什么有效我使用rabbitmq:3管理码头图像,...
有没有办法根据来自RabbitMQ的消息启动Quartz中的工作并使该消息的内容可用于该作业?
失败的K8s rabbitmq-peer-discovery-k8s群集
我正在尝试使用Rabbitmq-peer-discovery-k8s插件在Kubernetes上建立一个RabbitMQ集群,我总是只在pod上运行并准备就绪,但下一个总是失败。我尝试了多个......
我正在使用@RabbitListener注释和SimpleRabbitListenerContainerFactory bean来并行执行rabbitmq消息,并按以下方式设置最小和最大并发消费者:...
rabbitmq在一台服务器上有多个symfony2应用程序
我用RabbitMqBundle开发了一个Symfony2 Web应用程序,它工作正常。现在我正在尝试为其他开发人员设置更多相同应用程序的实例。那么,现在我有9个实例(...
在TomCat上没有配置的Task Executor的DirectMessageListenerContainer?
我正在为我的消息传递应用程序设置DirectMessageListenerContainer。我正在与Tomcat,Spring,AMQP合作。文档有这个警告https://docs.spring.io/spring-amqp/reference/#threading ...
cluster_formation.classic_config.nodes对rabbitmq不起作用
我有2个rabbitmq节点。他们的节点名是:rabbit @ testhost1和rabbit @ testhost2我想他们可以自动集群。在testhost1#cat /etc/rabbitmq/rabbitmq.conf cluster_formation ....
我正在使用MassTransit对抗RabbitMQ。在大多数情况下它运作良好,但一段时间后,消费者开始抛出一个S-FAULT警告:MassTransit.Messages警告:0:S-FAULT rabbitmq:// ...
我通过运行以下命令来创建rabbitmq容器docker run -d --hostname My-rabbit --name test-rabbit -p 15672:15672 rabbitmq:3-management创建了一个名为userrabbit的用户并给出了...
我正在寻找类似于https://www.rabbitmq.com/maxlength.html的内容,以获取队列中每条消息的消息大小。
Celery在远程任务上使用Django Result Backend
我有一个使用Celery创建异步任务的Django应用程序。其中一些任务存在于Django项目中,而其他任务存在于具有自己的代码库的远程工作者身上。我目前用的是......
您能否就如何在芹菜任务上分配自定义名称提出建议?默认情况下,它获取模块名称,但我想知道以防我想将任务发送到特定队列,我怎么能......
内存监视包含RabbitMQ侦听器的应用程序的Java堆大小用法
使用RabbitMQ和Spring AMQP我有一个包含一些@RabbitListeners的Java应用程序。这些消费者非常快速地收听队列并处理消息。我有兴趣知道记忆......
是否可以直接从命令行查看RabbitMQ消息内容? sudo rabbitmqctl list_queues列出了队列。有没有像sudo rabbitmqctl这样的命令命令...
Rabbitmq错误:[Errno 10054]远程主机强行关闭现有连接
我在Python中使用Kombu来使用持久的RabbitMQ队列。在Windows中只有一个消费者使用队列。此消费者产生以下错误:Traceback(最近一次调用最后一次):...