spring-rabbitmq

0热度

1回答

我有管理的春天AMQP客户端消息弹性的使用案例中的RabbitMQ服务器连接下来的情况下，因为我已经使用过Spring重试 RabbitTemplate template = // get template from some bean RetryTemplate retryTemplate = new RetryTemplate(); ExponentialBackOffPolicy ba

0热度

1回答

Spring RabbitMQ连接和资源管理问题

我需要通过HAProxy使用来自Rabbit HA群集的消息，因此我在spring-amqp-documentation中建议使用CacheMode.CONNECTION。此外我需要消耗许多队列中的消息，所以我创建的每个队列SimpleMessageListenerContainer有4个并发用户，我有几个问题：后几次测试看起来，我的做法是没有效率的，因为每次当一个新的队列也添加了新的Simpl

0热度

2回答

Spring AMQP监听器超时

我有处理SpringAMQP监听器超时能力的要求，即我们从生产者发送消息，Spring AMQP的消费者监听器线程接收到消息但说需要很多时间来执行自己并挂起，最终导致Listener线程无法使用。那么，有没有办法，我们必须由Spring AMQP提供任何消费超时设置让听者线程被释放再次给定的超时时间

1热度

1回答

如何使用rabbitmq docker的spring-boot创建rabbitmq中的队列

我已经失去了整整一天的时间，试图让spring-amqp示例项目运行并对docker版本的rabbitmq运行。我只是运行标准的rabbitmq docker。尽管我没有连接问题，但我总是会获得与创建队列有关的异常，并且我尝试了所有可能的变体。我试过在我的配置中像示例项目一样声明队列。我试过明确配置一个RabbitAdmin。我已经尝试明确配置整个自动配置混乱。我已经在rabbitmq中创建了一

2热度

1回答

如何使用RMQ和spring云流来创建基于分区的生产者？

我想找到春季云流的例子，它为RMQ创建基于parition的制作人。我想看看它将如何为这些队列创建绑定，因为RMQ不是本地支持主题的划分，但它会创建与分区数相当的队列数（我读过这个，可能是错的）。首先，我想了解如何使用基于分区的生产者的RMQ上的spring云流创建生产者。

0热度

1回答

如何使用Spring监视amqp/rabbitMQ连接？

我们有两个不同的AMQP服务器（RabbitMQ），并为每个服务器配置一个绑定器。检查每个amqp服务器的连接状态的最佳方法是什么？一种方法似乎是使用AmqpTemplate和CachingConnectionFactory，其中一个可以配置主机。但有没有更简单的方法？我也尝试过List<HealthIndicator>。但它只包含一个RabbitHealthIndicator应该有两个。我

0热度

1回答

TestSuite中模拟AMQPTemplate

我正在将JUnits作为TestSuite运行。其中一个JUnit类用于测试将消息发布到RabbitMQ的代码。我应该模拟代码将消息发布到MQ。我怎样才能做到这一点？是否可以简单地更改配置xml本身内的RabbitTemplate配置？类与业务逻辑： public class SomeClassImpl implements SomeClass { @Autowired @Quali

2热度

1回答

检索之前的序列化（审计）一RabbitMQ的消息

我有我想送它春云流之前审计的对象，问题就出现了，当我发送的对象为application/json所以拦截器接收对象的序列化串。杰克逊转换器之前可以运行拦截器吗？下面是拦截器的代码： @Slf4j public class AuditInterceptor implements ChannelInterceptor { private void updateField(Field fi

0热度

1回答

在RabbitMQ中的所有节点上的队列声明

我有一个Rabbitmq集群设置（没有HA）。我的客户是Spring应用程序，它提供了一个开箱即用的故障转移机制，它连接到下一个可用节点。由于队列没有镜像，因此如果我预先声明队列，并且当第一个节点关闭时，连接将建立到第二个节点，那么是否可以。这有意义吗？另一个问题，可以说我有一个负载平衡顶部的Rabbitmq群集。我的应用程序使用负载平衡连接。将队列在所有节点上声明还是将根据LB的路由策略在节

2热度

1回答

未绑定扇出交换丢失数据

当我向Fanout交换（它尚未绑定到任何队列）传递一些消息并停止发布者时，发送到交换器的消息将丢失。交换停止。未绑定的Exchange是否可以保存发布的消息？