使用Spring ampq在rabbitmq中重新排列消息
requeue the message in rabbitmq using Spring ampq

我是rabbitmq的新手,我正在尝试以下场景 - >生产者发送消息 - >消费者收到消息 - 如果逻辑失败,则执行我自己的逻辑 - 重新排队 - >重新排队...

RabbitMQ铲插件是否保留了消息排序?
Does the RabbitMQ shovel plugin preserve message ordering?

我使用RabbitMQ铲子插件(动态铲,见下文)通过不可靠的WAN链路在两个RabbitMQ代理之间提供单向消息传递。 我看到...中的常规连接丢失

实现RabbitMQ pub sub [关闭]
Implementing RabbitMQ pub sub

我正在尝试将基于RabbitMQ的pub sub合并到特定的编程场景中,我有一个Web API端点。 当我从这项服务得到201回复时,我想发送电子邮件。 我已经 ...

Spring AMPQ兔模板发布确认
Spring AMPQ rabbit-template publish confirmation

我试图在RabbitTemplate的帮助下使用RabbitMq(我正在使用Spring启动应用程序)。我能够做通信部分,它可以正常工作,但我有一个问题。 问题:怎么......

如何判断哪个amqp消息没有从basic.return响应路由?
How to tell which amqp message was not routed from basic.return response?

我正在使用带有node-amqp lib的RabbitMQ。 我正在发布带有强制标志设置的消息,当没有到任何队列的路由时,RabbitMQ会按照规范响应basic.return。 我的问题是......

如何订阅RabbitMQ通知消息?
How to subscribe for RabbitMQ notification messages?

我正在开发一个Qt5服务器应用程序,我正在使用QAMQP库。 我想要做的是以下内容:每当有关用户的某些内容应该更改时,另一台服务器应该发送消息...

RabbitMQ,重新连接后的传递标记值和消息顺序
RabbitMQ, delivery tag value and message order after reconnect

我使用pika for python与RabbitMQ进行通信。 我有6个线程,它使用和确认来自同一队列的消息。 我为每个线程使用不同的连接(和通道)。 所以我有......

Rabbitmq命令行不删除问题
Rabbitmq commandline does not delete ques

当我输入以下命令并重定向到文本文件时,以admin:C:\ Users \ snoopy \ Downloads> python.exe rabbitmqadmin.py -H dev-xxx.mydomain.com -P 15672 -u snoopy -p 123删除队列NAME =” ...

任务经理与aerospike和node.js
Task manager with aerospike and node.js

我在网络应用程序中使用node.js和aerospike。 当用户发布,提及或关注我必须在时间表或/和通知上做工作。 我想在node.js之后运行这些作业......

是什么原因导致amqp.node从RabbitMQ服务器获取ECONNRESET?
What causes amqp.node to get ECONNRESET from a RabbitMQ server?

我有一个在Windows 8环境中运行的RabbitMQ(默认配置)实例。 我的节点版本是5.1.0,我正在尝试使用amqp.node库在它们之间建立连接...

RabbitMQ / Pika - 保证在创建的订单中收到消息?
RabbitMQ / Pika - guaranteeing that messages are received in the order created?

举个简单的例子,我在新的RabbitMQ(v 2.6.1)队列中添加了5个项目:import pika connection = pika.BlockingConnection(pika.ConnectionParameters(host ='not.my.real.server.net')) channel = ...

如何在Ubuntu中增加RabbitMQ文件的描述限制
How to increase RabbitMQ file descripter limit in Ubuntu

我们非常接近1024的限制(如rabbitmq admin中所宣称的)我假设1024是用户rabbitmq的限制。 我们如何增加对ubuntu的限制,将其增加到一些任意...

无法理解流利/ td-agent发送机制
unable to understand fluentd/td-agent sending mechanism

嘿,我最近和流利的人一起工作。 所以问题是我正在创建一个环境,从不同的服务器流利的将把日志发送到中央系统,并在其中处理...

以django和兔子为经纪人的芹菜正在跳过每一项备用任务
Celery with django and rabbit as broker is skipping every alternate task

我正在使用芹菜为我的django应用程序做后台工作,并将rabbitmq作为经纪人。 但我在制作中遇到了奇怪的问题。 无论我发起什么任务,每个替代任务都会得到......

在Varnish中,HTTP方法PURGE是幂等的吗?
Is the HTTP method PURGE idempotent in Varnish?

HTTP动词PURGE是幂等的吗? 如果我两次发送相同的PURGE请求,我会第二次收到200吗? 我有一个微服务,在将消息发布到...之前使Varnish缓存无效

使用Spring Framework时如何删除RabbitTemplate?
How do I stub-out RabbitTemplate when using Spring Framework?

我正在尝试创建一些集成测试,我想要删除注入RabbitTemplate的构造函数。 这样做的最佳方式是什么? 这是当前应用的一个例子......

为什么在重新排队时从RabbitMQ获得相同的消息?
Why do I get the same message from RabbitMQ when requeueing?

背景我的队列中有两条消息:foo bar我有一个通道,一个消费者Qos处于活动状态,预取计数为1.场景消息传递foo进来,我拒绝...

如何在Rails中使用RabbitMQ实现RPC?
How to implement RPC with RabbitMQ in Rails?

我想实现一个用RabbitMQ调用远程服务的动作,并显示返回的数据。 我实现了这个(更多是作为概念证明到目前为止),类似于从这里采取的例子:...

Rabbit Mq状态检查
Rabbit Mq status check

在我的春天,使用了hibernate应用程序RMQ。 我在这个应用程序中有一个url来检查数据库连接的状态和线程的状态。 我还想包括RMQ的状态检查...

在Rabbit中提取,转换,加载?
Extract, transform, load within Rabbit?

出于性能原因,我经常做的一件事就是将SQL数据转换为缓存和基于文档的存储。 我不希望我的前端应用程序访问我的数据库,所以我...

通过连接发送数据
Sending data over a connection

我有一个Erlang应用程序,它产生了几个(可能是数千个)进程。 这些进程中的每一个都向接收json的远程服务发出http请求。 一旦流程收到......

有没有办法用芹菜推送消息到rabbitmq而没有在代码上定义任务
Is there a way of pushing messages to rabbitmq with celery without having the task defined on the code

我需要将我的应用程序堆栈分开,将web和worker作为单独的微服务,即它们都运行在不同的基础架构中,并且都具有不同的存储库。 阻拦者我得到的是......

当芹菜队列填充时,Django会阻塞吗?
Does Django Block When Celery Queue Fills?

我在我的网络应用程序上进行了一些度量分析,这大量使用了芹菜。 我有一个度量标准,用于测量从post_save信号到celery任务的完整行程(它本身称为...

RabbitMQ:直接回复?
RabbitMQ: direct reply-to?

有没有一个很好的例子(C#)如何在RabbitMQ中进行直接回复? 我想要做的是让X Producers发布消息(“我为某人做了一些工作”)并且我想要一个X消费者......

rabbitmq-plugin返回“错误无法识别命令”
rabbitmq-plugin returns "error could not recognize command"

我安装了适用于Windows Server 2012的rabbitmq。它安装得正确。我想在rabbitmq-plugin.bat中运行rabbitmq_management命令,但双击时的bat文件“错误可能......

RabbitMQ运行时使用<IP Address>给出AuthenticationException
RabbitMQ when running with <IP Address> giving AuthenticationException

我开发了一个小程序来连接rabbitMQ服务器。 我使用了所有默认设置。 方法public Connection getConnection(String host)抛出IOException,TimeoutException {...

如何使用Rabbit绑定创建带有Transaction和DLQ的处理器?
How to create Processor with Transaction and DLQ with Rabbit binding?

我刚刚开始学习Spring Cloud Streams和Dataflow,我想知道一个重要的用例。 我创建了示例处理器Multiplier,它接收消息并重新发送5次以...

ServiceStack.RabbitMq - 如何在消息上设置自定义属性
ServiceStack.RabbitMq - how to set custom attributes on messages

我们使用ServiceStack.RabbitMq,我找不到在Rabbit mq消息上放置自定义属性的方法。 我希望发布者在消息上设置属性,并让worker读取它。 一个 ...

node.js imqplib sendToQueue挂起到RabbitMQ
node.js imqplib sendToQueue to RabbitMQ is hanging

我有一个将消息排队到RabbitMQ的函数,如下所示:var amqp = require('amqplib / callback_api'); var _queueURL ='amqp://127.0.0.1'; var _toBlahBlahQueueName ='blahblah'; var self = module ....

在rabbitmq中创建集群时出错
Error while creating a cluster in rabbitmq

我是rabbitmq的新手并试图建立一个集群。 但是我收到以下错误。 在C:\ Windows和C:\ Users \ <用户在上下文>目录中的两台机器上的cookie都是相同的...

使用Windsor Integration时,从不调用MassTransit Consumer
MassTransit Consumer never invoked when using Windsor Integration

我似乎无法让Castle Windsor Integration通过RabbitMQ为Mass Transit工作。 一切都很好,直到我介绍温莎到图片。 我引用了Castle.Windsor 3.2和......

java spring rabbitmq让队列等待另一个
java spring rabbitmq make a queue wait for another

我有一个java spring应用程序和rabbitmq服务器。 我有两个队列。 第一个检查A是否在DB中。 第二个将A保存到db。 我的意思是听众。 但是,如果我用相同的A发送许多请求,...

SimpleMessageListenerContainer批量消息处理
SimpleMessageListenerContainer bulk message processing

我有一个传入数据流,作为单独的消息发送到RabbitMQ。 我想将这些发送到需要一批消息的服务。 当我......我需要将请求发送给服务

是否可以从activemq和rabbitmq实现通用的msg使用者?
Is it possible to implement a generic msg consumer from both activemq and rabbitmq?

我们当前的实现有一个抽象层,分离出(完全)一些接口apis,如start,close等,基本上遵循模板模式。 有没有更好的方法呢? 不......

添加一个用厨师安装rabbitmq的用户
adding a user installing rabbitmq with chef

使用管理插件成功安装了rabbitmq服务器:version ='4.5.1'run_list = [“recipe [rabbitmq :: default @#{version}]”,“recipe [rabbitmq :: mgmt_console @#{...

为用户在应用程序中创建的每个主题创建新队列
Creating a new queue for every topic created by the user in the app

我的应用程序使用Spring + RabbitMQ。 它已经设计了两个功能,在主页上显示用户和他朋友的帖子以及发生的任何事件的通知功能。 ...

RabbitMQ消息/主题接收器在RabbitMQ未运行时崩溃
RabbitMQ Message/Topic Receiver Crashing when RabbitMQ is not running

我在Linux OS环境中使用python和pika。 当RabbitMQ未运行时,消息/主题接收器不断崩溃。 我想知道有没有办法保持消息/主题接收器运行时......

RabbitMQ - 避免发布方的重复消息
RabbitMQ - Avoiding duplicate messages at publisher side

我正在使用RabbitMQ向用户发送通知。 用户可以随时读取他的队列。 我面临的问题是队列在夜间充满了大量通知,并且......

RabbitMq Consumer不处理消息
RabbitMq Consumer not processing messages

我已经将RabbitMQ的使用者作为用C#.NET编写的控制台应用程序。 它被编程为永久地监听队列,每当它在队列中找到消息时,它就会处理它。 ......

如何使用任何PHP库获取AMQP队列统计信息?
How to get AMQP queues stats using any PHP lib?

我找到了如何在Python,Java和JavaScript中获取队列统计数据的答案,但是我很难找到如何使用像PECL AMQP或php-amqp lib这样的PHP库。 只有一种可能的选择......

RabbitMQ消费者重新连接
RabbitMQ Consumer Reconnecting

这是场景:消费者(C)正在侦听队列(Q)上的消息,而发布者(P)正在向Q发布消息。当C等待消息被放到Q上时,Q被删除,然后P发布...

在RabbitMQ中使用不同交换的任何优势?
Any advantage using different Exchanges in RabbitMQ?

使用默认(直接)交换与为每个队列创建自定义直接交换有什么区别吗? (默认交换) - > queue1(默认交换) - > queue2 vs. ...

RabbitMQ:没有消费者连接时丢弃消息
RabbitMQ: dropping messages when no consumers are connected

我试图在一个只有一个生产者和一个消费者的模型中设置RabbitMQ,并且生产者发送的消息只有在消费者连接时才传递给消费者,但......

Rebus RabbitMQ对象序列化
Rebus RabbitMQ Object serialization

为什么我通过rebus向RabbitMQ发送消息,它正在添加如下所示的额外对象数据,主要是$ type。 {“$ type”:“ThreeSquared.VTGPAM.Objects.Wagon,ThreeSquared.VTGPAM.Objects”,...

多个服务器与Rabbit MQ交互
Multiple servers to interact with a Rabbit MQ

我正在为一家我们正在考虑Mule ESB的公司工作。 我们需要在群集配置中设置Mule,以获得Mule为Mule高可用性(HA)群集注入的内容。 现在,我们需要......

坚持理解如何构建可扩展的系统
Stuck with understanding how to build a scalable system

我需要一些关于如何正确构建一个能够扩展的系统的指导。 我会告诉你一些关于我要做什么的信息然后问我具体的问题。 我有一个网站......

我们可以加快通过RabbitMQ发布消息的速度
Can we speed up publishing messages via RabbitMQ

我正在我的Ubuntu工作站上运行一些测试。 这些基准测试从填充队列开始,运行速度非常慢:如果__name__ =='__ main__',则导入pika import datetime:try:...

确认拒绝AMQP消息的逻辑是什么?
What is the logic for acknowledging then rejecting an AMQP Message?

我一直在玩AMQP的RabbitMQ客户端,我注意到ack并拒绝这两个只是采取交付标签。 如果您确认然后拒绝相同的交货标签会发生什么? RabbitMQ不......

我可以从我的Python / kombu客户端获取RabbitMq连接ID吗?
Can I get RabbitMq connection id from my Python/kombu client?

当我运行此命令时:rabbitmqctl list_connections pid我得到如下输出:<rabbit@my_box.2.1234.0> <rabbit@my_box.2.1235.0>有没有办法从我的...读取此pid
1 2 3 4 5 6 7 44 45