使用Spring ampq请求Rabbitmq中的消息

Question

我是rabbitmq新手，正在尝试以下场景

--

如果逻辑失败-重新排队

--

我已经使用SpringRabbitTemplate实现了基本发送器

rabbitTemplate.convertAndSend(.....);

对于消费者，我实现了一个消息侦听器

public class CustomMessageListener implements MessageListener {
@Override
    public void onMessage(Message message) {
       //** my own logic**
   }
}

并通过Spring将其添加到容器中

  <bean id="aListener" class="com.sample.CustomMessageListener" autowire="byName"/>

 <rabbit:listener-container id="myListenerContainer" connection-factory="connectionFactory"  acknowledge="auto" prefetch="750" concurrency="5" >
    <rabbit:listener ref="aListener" queues="reportQueue"/>
</rabbit:listener-container>

直到这部分工作正常。

现在，如果侦听器中提到的**我自己的逻辑**失败。我想重新询问这个消息。我如何实现这一点。从我浏览过的博客来看，似乎需要覆盖returnedMessage。但我不确定如何通过listener实现。

Answer 1

使用acknowledge=“auto”，在侦听器正常退出之前，消息不会被确认，因此您不需要做任何额外的事情；如果侦听器引发异常或服务器崩溃，消息将保留在队列中。