spring-rabbitmq 相关问题

基于AMQP的消息传递的Spring组件。

供应商绑定不适用于Spring Cloud Stream Rabbit

[我们有如下来源，我们正在使用春季云流兔活页夹3.0.1.RELEASE。 @Component公共类处理程序{private EmitterProcessor sourceGenerator = ...

spring-cloud-stream spring-rabbitmq

回答 1 投票 0

由于发布者和订阅者位于受相同资源限制的同一应用程序中，背压如何帮助解决双方的负载问题？

java rx-java reactive-programming spring-rabbitmq backpressure

回答 2 投票 1

Spring @AliasFor不适用于注释@RabbitListener

[我正在尝试创建一个简单的元注释，它应该充当@RabbitListener，这是我的尝试：@Retention（RetentionPolicy.RUNTIME）@Target（{ElementType.TYPE，ElementType.METHOD，ElementType ....

spring spring-rabbitmq

回答 1 投票 0

一旦消息数量超过并发使用者数量，就不会将消费者分配给消息

我想了解消费者在消费一条消息后如何为并发消费者工作。是废弃消费者Bean并创建新的消费者Bean，还是重新使用消费者Bean？我可以看到...

java rabbitmq spring-rabbitmq

回答 1 投票 0

动态队列和侦听器，消息未发送？

兔子配置：包com.rabbitMQ;导入org.slf4j.Logger;导入org.slf4j.LoggerFactory;导入org.springframework.amqp.core.AmqpAdmin;导入org.springframework.amqp.core.AmqpTemplate; ...

java rabbitmq amqp spring-rabbitmq

回答 1 投票 0

RabbitMQ：连接丢失后如何处理不必要的重复取消确认消息？

在我的应用程序（多个实例）中，我们偶尔会看到由于网络问题（我的应用程序和Rabbitmq都处于活动状态）而导致我的应用程序和Rabbitmq之间失去连接的情况，然后在连接之后...

rabbitmq spring-rabbitmq

回答 1 投票 0

Mockito doAnswer（）

java spring mockito integration-testing spring-rabbitmq

回答 1 投票 0

如何获得Java中RabbitMQ的当前IP地址？

我有一个ConnectionFactory（org.springframework.amqp.rabbit.connection），其地址列表为@Bean（name =“ mainConnectionFactory”）@Primary public ConnectionFactory ...

java rabbitmq amqp spring-rabbitmq

回答 1 投票 0

Spring AMQP-发布者确认发布到不存在的队列时确认的返回结果

如果我使用发布者确认并在RabbitMQ上返回回调，则永远不会收到返回的消息。从Spring AMQP文档：-发布到交易所，但没有匹配的目标队列。 -发布...

spring-boot spring-amqp spring-rabbitmq spring-rabbit

回答 1 投票 0

Spring Cloud Stream RabbitMQ添加队列参数

我想知道如何向使用Spring Cloud Stream声明的rabbitmq队列添加额外的参数。我想对RabbitMQ 3.8.x使用单一活动使用者功能。为此，我必须添加一个...

rabbitmq spring-cloud spring-rabbitmq

回答 1 投票 0

Spring cloud Rabbit配置尝试连接到本地主机5672

有很多例子，其中使用Java代码来配置纯兔子，但是与Spring Boot相关的文档是另一回事。我的要求很基本-单个队列，单个...

spring-boot rabbitmq spring-rabbitmq

回答 2 投票 0

Spring AMQP（RabbitMQ）抛出通道关闭错误

我正在尝试通过创建MethodInterceptor ConsumerAdvice并将其添加到SMLC factor.setAdviceChain（new ConsumerAdvice（）），根据某种条件对channel.basicReject（）进行重新排队。我...

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

系统的消息使用者组件处理每条消息，并使用WebSockets照看者应用程序异步通知

我正在尝试通过websocket发送来自Rabbitmq消费者的通知，并将其发布到有角度的应用程序上。我对rabbitmq和websocket都是陌生的，我不知道该如何...

java spring-websocket spring-rabbitmq

回答 1 投票 0

在运行时使用SmartLifecycle问题添加队列

因此，这是与此相关的新问题，我创建了一个案例，其中ListenerContainer实际上在阶段0的@Bean之前运行，即使它具有阶段Integer.MAX_INT。这是代码：...

java rabbitmq spring-amqp spring-rabbitmq

回答 2 投票 0

Spring 3和Rabbit MQ集成（不是Spring Boot）

我很难使Spring 3应用程序与RabbitMQ集成，以便从队列接收消息（我不需要发送消息）。挑战的一部分是很多...

spring rabbitmq spring-rabbitmq

回答 1 投票 0

如何在DirectMessageListenerContainer中实现ApplicationListener

[任何人都可以指导如何在DirectMessageListenerContainer（spring Rabbitmq）中以编程方式注册ApplicationListener来处理ListenerContainerConsumerFailedEvent谢谢...

spring-rabbitmq

回答 1 投票 0

在等待客户端的channel.basicAck时，频道可以保持多长时间

我很好奇，如果没有意外错误，在等待客户端确认消息时（使用channel.basicAck（）），通道会保持活动状态吗？通道是否有超时参数？ ...

java rabbitmq spring-rabbitmq

回答 1 投票 2

Spring-Rabbitmq侦听器需要在数据库更改期间暂停和恢复

嘿，要求是在更改后端表期间暂停Rabbitmq侦听器处理消息。此更改仅限于我的应用程序，因此不想降低...

java rabbitmq spring-rabbitmq spring-rabbit

回答 1 投票 0

[当启用发布者确认时，设置了队列长度限制，并且将溢出设置为拒绝-发布，为什么导致我收到的确认回调为空？

我正在学习队列长度限制（https://www.rabbitmq.com/maxlength.html），正如上面所说，队列设置为'x-max-length：10'，并且'x-overflow：reject- publish”，也可以使发布者确认，所以...

java spring-boot spring-amqp spring-rabbitmq

回答 1 投票 1

Spring Cloud Stream具有自动重新连接Rabbitmq

失去连接后，我需要重新连接Rabbitmq。我想知道春天的云流是否有这个。感谢。

spring rabbitmq cloud spring-rabbitmq spring-rabbit

回答 1 投票 0

spring-rabbitmq 相关问题

最新问题