-
使用Spring AMQP自动恢复AMQP连接期间的AlreadyClosedException
在绑定到Rabbit MQ实例的Java应用程序的日志中,我们遇到以下异常的情况。 这是必须要解决的问题 -
在运行时使用SmartLifecycle添加队列时出现问题
因此,这是与<a href="https://stackoverflow.com/questions/57670878/spring-amqp-proper-way-to-register-queues-to-container-on-startup -
Spring Listener容器-事务管理器-Spring重试-多个事务之间
我通过RabbitMQ拥有Spring引导服务。 我正在开发测试,以确保流程在多个事务之间保持事务状态。</p -
如何使用Kotlin协程在Spring AMQP中使用消息?
我已经<a href="https://spring.io/blog/2019/04/12/going-reactive-with-spring-coroutines-and-kotlin-flow" rel="nofollow noreferrer">read -
春季AMQP(RabbitMQ)抛出通道关闭错误
我试图通过创建MethodInterceptor <code>channel.basicReject()</code>并将其添加到SMLC <code>ConsumerAdvice</code>来基于某 -
邮件丢失或未使用
我不知道发生什么事了。在队列中发布消息后,此消息永远不会被使用,但是消息将从队列中丢失。在 -
RabbitTransactionManager无法在ChainedTransactionManager上提交事务
我正在尝试为Rabbit和Kafka使用一个事务管理器。首先,我从Rabbit回调中获取一条消息,然后将其发送给Kaf -
Spring amqp + Spring data redis
我正在使用带有弹簧数据redis的spring amqp。我遇到的问题是,在关闭阶段,Redis连接会先关闭,而amqp仍会 -
Spring AMQP-发布者确认发布到不存在的队列时确认返回
如果我使用发布者确认并在RabbitMQ上返回回调,则永远不会收到返回的消息。 从Spring AMQP文档: <pre>< -
使用旧的Spring Rabbit 1.7.9将Spring Boot从1.5迁移到2.1.5导致以下异常
弹簧靴2.1.5 <br/> 春季兔子1.7.9 <br/> spring-amqp 1.7.9 使用旧版Spring Rabbit 1.7.9将Spring Boot从1.5迁移到2.1.5 -
超时后重新发送消息
我有一个放入Spring AMQP的对象列表。对象来自控制器。有一个服务可以处理这些对象。并且此服务可能因 -
Spring AMQP-检测拒绝的邮件吗?
Spring AMQP中是否可以检测到消费者何时拒绝了一条消息? 我的应用程序声明了交换,但使用者声 -
保证消息异步传递
我写了一个代码来保证消息的传递及其处理。但是它在一个线程中工作。 如何重构代码以使其在<strong> -
SpringAmqp拦截器中的处理程序方法名称
我将spring amqp与多方法侦听器结合使用,如下所示: <pre><code>@RabbitListener(queues = PLATFORM_COMMAND_QUEUE) @Co -
Spring RabbitMq-应用自定义有效负载转换器
如何在<code>payloadConverter</code>中应用自定义<code>MessagingMessageConverter</code>。它默认为<code>SimpleMessageConverter -
从springboot 2.0.2迁移到2.2.2时的JSON异化问题
我将项目从Spring Boot 2.0.2迁移到2.2.2,也从Java 8迁移到Java11。在此期间,刷新Spring总线时出现json的反序列 -
Spring AMQP Rabbit监听器在“ ApplicationReadyEvent”之前触发
在Spring应用程序启动时,我想在<code>Redis</code>中查找一个值,然后根据该值我想关闭或保留我拥有的消 -
为什么ConfirmCallback#confirm#CorrelationData仅具有一个属性ID而不是整个消息,以便我可以立即重新发送消息
我正在尝试一些有关使用<code>ConfirmCallback</code>进行消息传递的可靠性的事情。 到目前为止,我已 -
Spring AMQP:侦听动态创建的队列
我有一个RabbitListener,它可以连续不断地异步监听队列“用户消息”的用户消息。一切正常,除非队列中 -
Spring Boot AMQP并发侦听器顺序执行?
我有一个这样定义的Spring AMQP侦听器:- <pre><code>@RabbitListener(queues = "spring-boot-durable", concurrency=& -
如何在多个类中使用@RabbitListener?
我有一个使用RabbitMQ(spring-boot-starter-amqp)的Spring应用程序。 我想知道是否可以在不同的类之间使 -
当使用@SendTo发送时失去连接时,Spring AMQP如何访问响应消息
我们有一个微服务,该微服务使用@RabbitListener消耗一条消息并将数据持久保存到数据库中,在成功处理 -
显示有关AMQP的信息时,这是否是窃听器错误?
我正在使用<code>spring-amqp</code>并测试<code>RabbitListener</code>#<code>AcknowledgeMode</code>。 当我设置<code>R -
为什么CachingConnectionFactory缓存通道,因为通道是虚拟连接?
<a href="https://www.rabbitmq.com/channels.html" rel="nofollow noreferrer">Doc</a>说: <pre><code>Some applications need multiple -
Spring AMQP恢复器无法与SimpleMessageListenerContainer
我正在尝试在春季amqp中实施恢复。我已经使用下面的代码实现相同的功能 <pre><code>RetryOperationsIntercep -
SpringAMQP-如何捕获ListenerExecutionFailedException?
我有3个队列。 <strong>队列主体</strong> <strong>队列重试(由代码控制3倍)</strong> <s -
使用Spring Boot在RabbitMQ上连续调用MessageListener.onMessage
我有一个带有线程睡眠的MessageListener.onMessage。我正在模拟onMessage的实际处理时间 该方法将由上述线程睡 -
将邮件从“答复”队列复制到另一个队列
我主要在RPC模式下使用RabbitMq,但我也想将请求消息和响应消息都复制到另一个队列中。 最后,我 -
仅当存在交换时,才如何使用Spring AMQP绑定到主题?
我需要将队列绑定到主题交换,但是: <ol> <li>仅当主题存在时</li> <li>如果该主题存在,请使用现有 -
升级到Spring Cloud Hoxton.SR3后接收AMQP消息时发生ClassNotFoundException
在将Spring Cloud从Hoxton.SR1升级到Hoxton.SR3之后,即使仍按预期方式处理消息,我们的应用程序也会在每次收