Rabbit mQ сообщения, перемещающиеся из готовой очереди в очередь Unack

Question

У меня есть отдельный издатель и потребитель. Я начинаю издавать и публиковать сообщения. Теперь я начинаю потребитель, и проблема в том, что сообщения переходят из готовой очереди, чтобы разблокировать очередность, отмечая сообщения как повторно отправленные которые я хочу avoid.So то, что я хочу, это должно быть помечено как только если повторно доставлена ​​я отправить извед, а не на потребителя перезагрузки или запуска

Конфигурация:

@Bean 
public org.springframework.amqp.rabbit.connection.Connection mqConnection() { 
    CloudFactory cloudFactory = new CloudFactory(); 
    Cloud cloud = cloudFactory.getCloud(); 
    return cloud.getServiceConnector("mqservicename", ConnectionFactory.class, 
      null).createConnection(); 
} 
@Bean 
public StatefulRetryOperationsInterceptor interceptor() { 
     return RetryInterceptorBuilder.stateful().retryOperations(retryTemplate()).recoverer(new RejectAndDontRequeueRecoverer()) 

      .build(); 
} 
@Bean 
public SimpleMessageListenerContainer listenerContainer() { 
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); 
    container.setMessageListener(new MessageListenerAdapter()); 
    container.setAdviceChain(new Advice[] { 
      interceptor() 
    }); 

    return container; 
} 



@Bean 
public RetryTemplate retryTemplate(){ 
    Map map=new HashMap<Class<? extends Throwable>, Boolean>(); 
    map.put(CustomException.class, true); 
    RetryTemplate retryTemplate=new RetryTemplate(); 
    retryTemplate.setRetryPolicy(new SimpleRetryPolicy(3,map)); 
    return retryTemplate; 
} 

Answer 1

Если вы используете Spring AMQP, ты необходимо указать свою конфигурацию, задавая такие вопросы.

Если вы установили режим ack в MANUAL, вы несете ответственность за файлы. Прочитано the documentation. Для AUTO ackmode контейнер будет выдавать сообщение, когда слушатель возвращается нормально.