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

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

RabbitMQ,如何在重新排队尝试后删除消息
RabbitMQ, How to drop a message after n re-queuing attempt

我试图通过使用RabbitMQ和JAVA来构建一种异步服务器。 我有两个交换机Original_Exch和Dead_Exch,每个交换机都有一个队列。 这两个交易所都被宣布为DLX(死...

SpringAMQP延迟
SpringAMQP delay

我无法确定在SpringAMQP中延迟消息级别的方法。 如果服务不可用,或者如果它抛出一些异常我将所有请求存储到RabbitMQ中,我调用Web服务...

如何通过相关ID将RabbitMq消息聚合为单个消息
How to aggregate RabbitMq messages into single message by correlation ID

假设我有一系列需要顺序执行的命令,而且有些命令包含多个应该并行执行的操作(相同的相关ID)。 ...

如何监控RabbitMQ交换生命周期事件
How do I monitor RabbitMQ exchange lifecycle events

我正在使用一个产品套件,它使用RabbitMQ作为服务总线消息传递的后端。 许多客户使用软件(NeuronESB),它应该自动配置交换,...

什么是RabbitMQ中的联合和备用交换
What is Federated and Alternate Exchange in RabbitMQ

我在这些交易所找到了两个链接。 https://www.rabbitmq.com/federated-exchanges.html和https://www.rabbitmq.com/ae.html但无法得到作者试图说的内容。 有谁有想法......

如何将erlang dbg附加到正在运行的进程?
How to attach erlang dbg to a running process?

如何将调试器附加到正在运行的erlang进程(rabbitmq)? 我有正在运行的相同兔子版本的源代码。 我想在源代码行上设置断点,并附加一个......

测试RabbitMQ交换
Testing RabbitMQ Exchanges

我正在尝试编写一个应用程序来测试N个交换绑定到内存,IO等相同队列的效果。测试都使用“主题”交换类型。 我遇到的问题是......

RabbitMQ - 如何联合/镜像消息
RabbitMQ - How to Federate / Mirror Messages

我设置了两个节点,A和B.两个节点都安装了RabbitMQ和联合插件。 在Web UI中,我可以看到“联邦状态”>“状态”在A和B上“正在运行”。在A上,我创建了一个队列...

将数据从postgres传输到rabbitmq
Transfering data from postgres to rabbitmq

我很安静新兔子,目前正在尝试安装Postgres监听交换插件:https://github.com/aweber/pgsql-listen-exchange我试过按照那里列出的说明,但我...

RabbitMQ:如何从curl中删除/移动队列中的消息
RabbitMQ: How to delete/move messages in queue from curl

我有多个RabbitMQ服务器。 我需要一个接口(使用JSP),我可以管理(删除所有这些服务器的队列/交换/消息)。 在内部,我将调用curl命令来执行操作。 ...

RabbitMQ中长时间未确认的消息
Long time unacknowledged message in RabbitMQ

我有一个业务流程从RabbitMQ队列接收订单。 我正在考虑不承认它(意思是,留在队列中)可能很长一段时间(> 10分钟)并且只...

应用程序异常关闭时删除RabbitMQ队列
Delete RabbitMQ Queue when Application is closed abnormally

我正在使用.NET RabbitMQ客户端库。 我想开发一个消息传递系统。 为此,我实现了RabbitMQ的所有必要方法。 此外,我已经开发了dispose()来删除队列。 一世 ...

如何通过puppet配置rabbitmq队列
How do I configure rabbitmq queue via puppet

我正试图通过木偶安装rabbitmq。 我正在使用puppetlabs-rabbitmq模块。 它还有用于配置队列和交换的部分,它们是本机类型。 我无法弄清楚如何使用这些......

Rabbitmq - 如何在交易所收听消息
Rabbitmq - how to listen to messages on an exchange

我有一个Java程序,它向RabbitMQ发送消息。 我所知道的只是交换名称。 没有队列,绑定等。 我的问题是:如何查看程序是否成功发送,...

为什么我不应该使用rabbitmq主题交换?
Why shouldn't I use rabbitmq topic exchanges for everything?

看起来工作模式,扇出和过滤的主题都可以通过主题交换来实现。 为什么我会使用直接或扇出交换呢? 我们想编纂共同的...

RabbitMQ CLI状态与管理门户不同
RabbitMQ CLI status different from management portal

我注意到当我从命令行(rabbitmqctl status)运行RabbitMQ状态命令时,所有报告的数字都与我所知道的现实完全不同。 我的现实是......

在ttl之后,死信的消息没有被重新排队到原始队列
Dead-letterred messages not getting requeue to original queue after ttl

我已经计划通过跟随这两个链接link1 link2来延迟队列中消息的处理。 所以,正如链接中所建议的那样。 我用x-dead-letter-exchange声明了原始队列...

RabbitMQ备份特定队列中的消息
RabbitMQ back up messages in specific queue

我有一个服务,它使用来自RabbitMQ队列的消息(通过主题交换发送到队列)。 假设服务理论上可以失败并失去其状态,可能性......

兔子mq的负载均衡选项
Load balancing options with rabbit mq

RabbitMQ可用于负载平衡的选项有哪些。 我已经去了http://insidethecpu.com/2014/11/17/load-balancing-a-rabbitmq-cluster/这篇文章。 有没有 ...

Rabbitmq标题交换和确认交付
Rabbitmq headers exchange and confirmed delivery

我正在尝试在RabbitMQ上使用标头交换,使用混合的java和python组件,我需要确认交付。 我似乎从python(pika)和java客户端获得了不同的行为。 ...

使用NServiceBus在生产中设置RabbitMQ集群的最佳实践
Best Practice for setting up RabbitMQ cluster in production with NServiceBus

目前我们有2个负载均衡的Web服务器。 我们刚刚开始在NSB上公开一些功能。 如果我创建两个“app”服务器,我会在所有4个服务器之间创建一个集群吗? 或者我应该......

RabbitMQ路由密钥
RabbitMQ Routing Keys

美好的一天。 有没有办法通过基于浏览器的UI检索现有交换(扇出或主题)的路由键? 我无权访问客户端源代码(生产者)以查看哪个路由...

RabbitMq主题交换
RabbitMq topic exchange

是否可以使用RabbitMQ主题交换实现以下场景。 假设我有两个队列:Queue1:路由键MainRoute.Route1 Queue2:路由键MainRoute.Route2当我发布时......

在有限的重新尝试之后从兔子MQ中删除消息
Remove message from rabbit MQ after limited attempts of requeing

我把文件中的记录放入兔子mq,从队列中读取记录并调用服务。对于被拒绝的记录,我发送一个否定的确认并用channel.basicNack方法重新排队。但是...

如何在Spring RabbitMQ项目中使用多个vhost?
How to use multiple vhosts in a Spring RabbitMQ project?

我有以下两个配置类:@Configuration @EnableRabbit @Import({LocalRabbitConfigA.class,CloudRabbitConfigA.class})公共类RabbitConfigA {@Autowired @Qualifier(“...

Rabbitmq文件描述符限制
Rabbitmq File Descriptor Limit

Rabbitmq文档说我们需要在生产之前进行一些配置。 其中一个配置是关于最大打开文件号(这是一个OS参数)。 Rabbitmq ......

如何使用交换重用RabbitMQ队列?
How to reuse RabbitMQ queues using exchanges?

我将解释我想要实现什么,然后我做了什么(没有结果)我有两个节点服务连接它们与RabbitMQ ussing交换(主题):我想要的是关闭C1 ...

是否可以在RabbitMQ中使用交换?
Is it possible to consume an exchange in RabbitMQ?

也许我在这里问错了问题。 我正在尝试做的事情:多个生产者将动态类别中的数据推送到命名交换中。 多个消费者需要从这些数据中获取这些数据......

使用MassTransit使用交换和路由密钥发布消息
Publish message using exchange and routing key using MassTransit

我一直在看MassTransit几个星期了,我很好奇这些可能性。 但是,我似乎无法将这些概念完全正确。 我想要的预期行为......

RabbitMQ路由密钥不路由
RabbitMQ routing key does not route

我正在尝试用RabitMQ做一个简单的消息队列我用create_message推送一条消息,然后尝试通过路由键获取消息。 当路由键相同时,它工作得很好。 ......

如何在兔子消息被删除时指定其他信息
How to specify additional info on a rabbit message when it's dead lettered

我有一个带有消息的兔子队列。 我也有一个可能失败的听众。 队列配置有死信交换(以及死信队列)。 我想要的是看到......

Spring-boot-starter RabbitMQ全局错误处理
Spring-boot-starter RabbitMQ global error handling

我使用spring-boot-starter-amqp 1.4.2.Producer和consumer工作正常,但有时传入的JSON消息的语法不正确。 这导致以下(正确的)异常:org ....

RabbitMQ Consumer不接收从Producer发送的消息
RabbitMQ Consumer not receiving messages sent from Producer

嗨,我想通过rabbitMQ发送消息。 我宣布直接交换并将其路由到生产者端的队列,但我无法收到消费者的消息。 以下是......

使用“。”是安全的,有MQTT主题级别分隔符而不是“/”吗?
It is safe to use "." has MQTT topic level separator instead of "/"?

有几个设备使用MQTT协议连接到RabbitMQ,有许多nodejs进程使用AMPQ协议订阅RabbitMQ以从这些设备获取数据。 这些设备是......

如何根据发布者RabbitMQ设置的消息的优先级由消费者获取消息
How to get Messages by the consumer according to priority of the messages set by the publishers RabbitMQ

我已经为单个消费者发布了一些优先级设置的消息(即可以根据消息优先级接收消息的单个消费者)。 我想要的是获取消息并打印出来......

RabbitMQ路由行为
RabbitMQ routing behavior

我正试图通过RabbitMQ向2个不同的队列发布消息,但事情并不像我预期的那样,这里是细节:我有一个交换:amq.fanout,类型:扇出,绑定是......

RabbitMQ在扇出交换时重试逻辑
RabbitMQ retry logic on fanout exchange

当前围绕RabbitMQ的系统架构我们有一组队列和交换来支持消息。 主要交换:这是从消息生产者收到的消息,用于处理第一个...

如何在RabbitMQ 3.5.6的自定义交换中修改传递(消息)?
How can I modify delivery(message) inside custom exchange for RabbitMQ 3.5.6?

我正在为RabbitMQ编写定制交换,它必须从交换中获取参数并将它们放到消息标题中。 我对Erlang不太熟悉。 - 模(...

curl发送JSON负载
curl send JSON payload

我只是在用RabbitMQ进行评论,我尝试发送一个json有效载荷给它。 不幸的是我得到错误:{“错误”:“bad_request”,“原因”:“payload_not_string”}我读的地方,我需要使用“...

RabbitMQ延迟交换插件负载和资源
RabbitMQ delayed exchange plugin loads and resources

我们使用rabbitmq(3.6.6)将分析(百万)发送给不同的分析仪。 这些都非常快,我们正在计划使用rabbit-message-plugin来安排监控...

如何在RabbitMQ中将消息从一个队列移动到另一个队列
How to move messages from one queue to another in RabbitMQ

在RabbitMQ中,我有一个失败队列,其中包含来自不同队列的所有失败消息。 现在我想给'重试'的功能,以便管理员可以再次移动失败...

默认rabbitmq交换类型
Default rabbitmq exchange type

根据我的理解,RabbitMQ服务器默认创建交换类型直接即如果我创建交换没有提供任何类型它将创建交换类型Direct.Is有任何方式通过... ...

RabbitMQ不会在无效的路由密钥上抛出错误
RabbitMQ not throwing error on invalid routing key

我在C#中有以下代码,如果路由键无效,它不会抛出错误。 var connFactory = GetConnectionFactory(); 使用(var conn = connFactory.CreateConnection()){using(...

为请求响应模型选择RabbitMq交换类型
Choosing RabbitMq Exchange Type for Request Reponse Model

我们正在将现有体系结构迁移到基于队列的体系结构。 我们的系统包含一个连接到300多个KIOSK系统的集中式服务器,其中数据同步是......

如何从Spring集成中获取RabbitMQ的头文件
How to get header from RabbitMQ with spring integration

为了使用延迟交换,我使用这种方法通过“int:gateway”消息发送给RabbitMq:void send(@Payload Notification request,@Header(MessageProperties.X_DELAY)Integer delay,@ ...

如何动态扩展RabbitMQ中的队列?
How to scale up the queue in RabbitMQ dynamically?

我可以使用RabbitMQ动态创建队列吗? 在我的应用程序中,我希望队列在队列满时动态扩展。我可以使用RabbitMQ来实现吗? 提前致谢。

使用Spring和RabbitMQ与已有的队列一起实现请求/响应模式
Implementing Request/Reply Pattern with Spring and RabbitMQ with already existing queues

让我从描述系统开始。 有2个应用程序,我们称它们为客户端和服务器。 还有2个队列,请求队列和应答队列。 客户端发布到请求队列,...

在RabbitMQ中使用声明Exchange
Use of declaring Exchange in RabbitMQ

我只是在RabbitMQ上做项目,我的代码片段就在下面的代码中:public static void Main(){var factory = new ConnectionFactory(){HostName =“localhost”}; 使用(var ...