问题标签 [spring-rabbit]

我有一个要求，其中（RabbitMQ）服务器将请求发送到客户端，客户端执行操作并将响应发送回服务器。

我想知道该主题使用哪种机制，PubSub，路由...我们可以在rabbit mq中创建类似于xmpp的服务器-客户端的双向连接，如果可以，我们该怎么做？

谢谢洛克什

在使用 Spring-AMQP 处理 RabbitMQ 时获得库存。

只需要获得一种使用 Spring-AMQP 配置 AutomaticRecoveryEnabled 和 NetworkRecoveryInterval 的方法。如果您使用本机 RabbitMQ 库进行开发，则可以直接选择设置这些标志。但我没有找到使用弹簧做同样的解决方法

使用 RabbitMQ Native 库（不需要任何帮助）

使用 Spring-AMPQ（需要帮助）

像上面一样，我在尝试使用 Spring-AMPQ 时没有找到任何这样的方法。这就是我现在正在做的事情。

在这方面的任何帮助都是非常可观的。提前致谢。

我需要在我开发的 Flume 自定义源中收听 Rabbit Queue。这个要求在 Flume 中可能看起来很尴尬。但这就是它的需要。为了简单起见，我使用 Spring AMQP 来监听队列，我只是无法理解如何在 Flume 生命周期的 Start() 方法中调用 OnMessage() 方法，以便将消息发布到 Flume 通道上。我已经查看了 Spring MessageListenerAdapter 概念，但我找不到任何示例来实现相同的概念。

我有一个场景，其中有一个应用程序正在生成不同类型的有趣事件（不是命令）。生产者应用程序不关心由谁以及如何处理事件。

我正在实现一个消费者，他将听取一些已发布的事件并适当地处理它们。消费者应用程序想要检查发布者应用程序交换是否存在。那么，问题是如何通过使用 spring 提供的 rabbit/AMQP 库来检查是否存在具有特定名称的交换？

我想，这可以通过尝试将队列绑定到不存在的交换来间接处理，从而导致异常。我正在寻找更好的方法来处理这种情况。

在处理来自 RabbitMQ 的消息时出现异常，我只想取消确认并将特定消息放回差异队列，或者重新排队到同一个队列或完全丢弃消息（根据 basicNack 中的最后一个布尔标志@requeue）。

整个想法是稍后我可以获得未确认消息的计数并检查消息格式等，而不是一次又一次地重新排队到同一个频道，而且我想将未确认的信号发送到当前频道。

仅供参考，我将通道确认模式设置为手动（即 container.setAcknowledgeMode(AcknowledgeMode.MANUAL);）

这就是我现在正在做的事情。

任何帮助都是非常可观的。

我正在使用 Spring AMQP 库。如何在 CachingConnectionFactory 中配置 connectionTimeouts 和 socketTimeouts。我假设它必须在内部使用 http://www.rabbitmq.com/javadoc/com/rabbitmq/client/ConnectionFactory.html#setConnectionTimeout(int)

我需要让我的 RabbitMQ 消费者连接到不同主机上的多个队列。如何让多个连接将消息发送到同一onMessage方法？我在3.5.2 异步消费者中尝试了2和1中的@Configuration样式，但只有其中一个接收消息。SimpleMessageListenerContainerConnectionFactoryMessageListener

此处的配置代码：https ://gist.github.com/mcamilleri/7212dd18d2010bf6695b （我有一个类似的类ConsumerConfiguration2，它只使用不同的主机名）。MessageListener在一个单独的班级。

我有一个绑定到交换的队列，如下所示：

对于这个队列，我绑定了一个死信交换，如下所示：

我已将死信队列绑定到死信交换，如下所示：

死信队列的声明方式如下：

但是，当我查看normal_queue其详细信息时，仅显示以下参数：

死信交换应该列在这里吗？这是否意味着没有正确设置死信交换？

当 RabbitMQ 配置为集群工作并重新启动主节点时，org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer 无法恢复并且无法使用消息（来自 RabbitMQ）。

spring-rabbit 版本：1.3.3.RELEASE

RabbitMQ 版本：3.3.1

当集群的主节点重新启动时，我们会得到以下异常：

我正在使用org.springframework.amqp.rabbit.connection.CachingConnectionFactory连接到 RabbitMQ。但是我的应用程序在断开连接后不会自动重新连接到兔子服务器（因为网络问题）

是否有任何配置可以进行CachingConnectionFactory自动重新连接？