spring-amqp 相关问题

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

带有并发使用者的Springboot RabbitMQ

我有一个简单的体系结构，其中三个进程之一（实际上是一个春季启动的dockerized容器）向交换/队列生成数千条消息，并且所有三个进程都消耗这些消息...

java spring-boot rabbitmq spring-amqp

回答 1 投票 3

根据RabbitMQ中的邮件正文属性有选择地使用邮件

假设我有一种情况，我需要等待1分钟才能执行某些操作。如果已过期，请尝试其他操作。我当前的解决方案建议基于RabbitMQ ...

rabbitmq amqp spring-amqp

回答 1 投票 0

如何通过配置禁用兔子健康检查

我想在默认的RabbitMockConfiguration中禁用兔子健康检查。我们有一个通过@Import导入的配置。不幸的是，该配置不会阻止健康...

spring spring-boot spring-amqp spring-rabbitmq

回答 2 投票 0

我如何直接将消息发送到停车场队列，防止重新排队并退出程序流？

我目前有4个队列：测试队列测试队列短期死亡信测试队列长期死信测试队列停车位当消息进入测试队列时，我检查一下...

java rabbitmq message-queue spring-amqp

回答 1 投票 0

RabbitMQ-在删除队列之前移动消息

使用RabbitMQ 3.7.16，带有spring-amqp 2.2.3版本。多个客户端将消息发布到我们RabbitMQ服务器中的主题交换。为了分别按...

rabbitmq amqp spring-amqp spring-rabbitmq rabbitmq-exchange

回答 1 投票 1

Spring Cloudstream 3 + RabbitMQ配置到现有队列

我正在学习Cloudstream，无法将cloudstream功能映射到现有队列中。我只是从Spring Cloud文档创建hello world应用程序，但实际上不是...

spring-boot spring-cloud-stream spring-amqp

回答 1 投票 0

仅在存在交换的情况下如何使用Spring AMQP绑定到主题？

我需要将队列绑定到主题交换，但是：仅当主题存在时如果主题存在，请使用现有设置（例如，持久性，自动删除等）原因是，我需要第三方应用程序。。

spring spring-amqp spring-rabbitmq

回答 1 投票 0

将邮件从“答复”队列复制到另一个队列

我主要在RPC模式下使用RabbitMq，但我也想将请求和响应消息都复制到另一个队列。最后，我要实现的是外部消费者的可能性...

rabbitmq spring-amqp

回答 2 投票 0

[MessageListener.onMessage在带有Spring Boot的RabbitMQ上不断被调用

我有带线程睡眠的MessageListener.onMessage。我正在模拟onMessage方法将由上述线程睡眠占用的实际处理时间。但是我注意到的是...

spring-boot rabbitmq spring-amqp

回答 1 投票 0

RabbitMQ：将邮件从“答复”队列复制到另一个队列

我主要在RPC模式下使用RabbitMq，但我也想将请求和响应消息都复制到另一个队列。最后，我要实现的是外部消费者的可能性...

rabbitmq spring-amqp

回答 1 投票 0

Spring AMQP恢复器不适用于SimpleMessageListenerContainer

我正在尝试在春季amqp中实施恢复。我使用下面的代码来实现相同的RetryOperationsInterceptor retryInterceptorBuilder = RetryInterceptorBuilder.stateless（）...

spring rabbitmq spring-amqp

回答 1 投票 1

Spring AMQP在使用@SendTo发送时失去连接时如何访问响应消息

我们有一个微服务，该微服务使用@RabbitListener消耗一条消息并将数据持久存储到数据库中，在成功处理消息后生成响应，并使用@sendTO将其发送到不同的...

spring-amqp spring-rabbitmq spring-rabbit

回答 1 投票 0

Spring AMQP Rabbit监听器在“ ApplicationReadyEvent”之前触发

在Spring应用程序启动时，我想在Redis中查找一个值，根据该值，我想关闭或保留我拥有的消息侦听器。也可以不...

spring spring-boot rabbitmq spring-amqp spring-rabbit

回答 1 投票 0

将Spring Boot从1.5迁移到2.1.5，使用旧版Spring Rabbit 1.7.9导致以下异常

spring boot 2.1.5 spring-rabbit 1.7.9 spring-amqp 1.7.9将Spring Boot从1.5迁移到2.1.5，使用旧的Spring Rabbit 1.7.9导致部署时发生以下异常：java.net.URLClassLoader@763d9750 .. 。

spring-amqp

回答 1 投票 0

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

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

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

回答 1 投票 0

RabbitTransactionManager无法在ChainedTransactionManager上提交事务

我正在尝试为Rabbit和Kafka使用一个事务管理器。首先，我从Rabbit回调中获取一条消息，然后将其发送给Kafka主题。但是我总是得到一个异常，表明Rabbit ...

apache-kafka transactions rabbitmq spring-kafka spring-amqp

回答 1 投票 1

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

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

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

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

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

java rabbitmq spring-amqp spring-rabbitmq

回答 2 投票 0

使用Spring AMQP自动恢复AMQP连接期间的AlreadyClosedException

我们在绑定到Rabbit MQ实例的Java应用程序的日志中遇到以下异常的情况。这是必须要解决的问题，它表示......>

java spring rabbitmq spring-amqp

回答 1 投票 0

与RabbitMQ的模拟连接

我有一个带有Spring AMQP的Spring应用程序。我想运行以H2数据库启动Spring的JUnit测试。但是对于Spring AMQP，我在启动过程中遇到此异常：由org.springframework ....]造成]

java spring junit spring-amqp junit5

回答 2 投票 0

最新问题

© www.soinside.com 2019 - 2024. All rights reserved.