问题标签 [spring-amqp]

创建了具有两个 rabbitMQ 节点的集群。rabbit1 和 rabbit2 节点的配置如下。

2> 节点类型rabbit1 - 磁盘节点rabbit2 - ram 节点3> 生产者和消费者程序位于rabbit2 节点（即> ram 节点）

感谢您对此的任何帮助。

在设计 RabbitMQ 集群时，Spring AMQP 中的 HAProxy 有什么用？那是 Spring AMQP 的一部分还是需要配置外部？提前致谢。

Spring-AMQP 的一个很好的特性是它似乎实现了在代理关闭和恢复时将 Spring 应用程序重新连接到消息代理所需的逻辑。

我正在寻找的是检测应用程序中何时发生此类断开/重新连接事件的首选方法。

到目前为止，我想出的最好的方法是一种类似轮询的机制，我尝试定期从连接工厂获取通道。

提前致谢！

我是 Spring Integration 和 Spring Integration AMQP 的新手。

我有以下代码：

设置如下：

一切工作正常，除了入站通道适配器接收消息时标头丢失。

同样，当使用 outbound-channel-adapter 将消息发送到交换器时，称为“存储”的被丰富的标头也会丢失。

这是消息在被入站通道适配器接收之前的样子：

这就是同一条消息在整个过程中的处理方式（注意没有标题）

我有以下 XML 有效负载，我正在尝试将其用于 Spring Integration 和 Spring Integration AMQP：

我正在使用 xpath-splitter 拆分消息：

我工作正常，消息被拆分为 3 条新消息，例如使用此有效负载：

在此步骤之后，将使用此设置聚合消息：

作为最后一步，使用此出站通道适配器将消息发送到交换：

不幸的是，出了点问题，因为我最终得到了类似这个有效载荷的东西。我需要它保持 XML 格式。

我们正在尝试使用 Spring AMQP 在 RabbitMQ 中进行异步调用，有人可以告诉我如何使用 spring amqp 配置回复队列、correlationId、（属性）吗？

正如标题所说，我们在使用 Esper 和 RabbitMQ 构建项目时遇到了问题。因此我们需要使用 Esperio（4.10 版）的 amqp 适配器。

我们从手册中的基础开始，但由于某种原因，我们的查询没有得到应有的评估。我们已经发现需要在 amqp 适配器的声明中切换“EventBusSink”和 EventBusSource（构建错误，例如“未定义输出流”）

我们使用 Spring AMQP 在 Rabbitmq 中设置了 2 个队列，如下所示：

并像这样配置 Esper 和 amqp 适配器：

当我们在一个方法（构造函数或初始化方法）中设置配置和发布多个语句时，一切正常。但是，当我们第一次使用自定义配置（使用适配器）启动 esper 并在稍后阶段发布语句（并随后发送事件以匹配这些语句）时，没有任何内容与我们的语句匹配。尽管如此，我们使用相同的 esperProvider（我们代码中的 epService）。当我们在发布语句的方法中复制配置部分时，我们会得到一个异常，指出适配器已经存在。

一个查询的例子是：

发送的事件：

Esper 在运行时发布语句是否有任何限制？

谢谢！

亚娜

我有使用 Spring AMQP 进行同步消息传递的代码，如下所示。我的场景是当生产者发送消息时，它期望得到响应。因此，任何人都可以帮助解决如何在同步消息的情况下发回响应。

我知道我们可以handleMessage()在异步消息传递的情况下使用。但是，使用上面的 API 如何在同步消息的情况下发回响应？你能帮我解决这个问题吗？

提前致谢。

我有一个通过 spring-amqp 框架配置的异步消费者：

来自 3rd 方应用程序的外部事件向我的服务器表明它已准备好处理数据，此时我想从我订阅的队列中获取消息并针对 3rd 方应用程序处理它们。

我的handleMessage方法的工作是将消息排队，直到收到来自 3rd 方应用程序的就绪事件。但是我不想排队太多，这会破坏将RabbitMQ放在中间的目的。此外，任何可以通过在接收到就绪事件时不显式获取消息来实现的优化都将丢失。

是否有某种方式表明我想在达到上限后暂停订阅？会QueueingConsumer在这里以某种方式相关吗？

我在整个互联网上都听说 rabbitMQ 不支持事务。

现在，也就是说，spring 框架为我们提供了一个兔子事务管理器：

这是其定义的片段：

所以我的问题是：

1）在带有事务管理器的方法上使用@transactional注解实际上可以保证事务效果吗？2）spring是如何在rabbit非跨国的情况下实现交易的？