ウサギのmQメッセージがレディキューからUnackキューに移動

Question

私は別のパブリッシャとコンシューマを持っています。パブリッシャとパブリッシュメッセージを開始します。私はコンシューマを開始し、問題はレディキューからメッセージを再キューに入れるあなたは、あなたが春AMQPを使用している場合

@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

：これは私が欲しいものavoid.Soたいのは、私はACK送信していない消費者の再起動や

Configurationを起動した場合にのみ再配信として、それがマークされるべきですこのような質問をするときに設定を表示する必要があります。

ackモードをMANUALに設定すると、acksの責任を負います。 the documentationを読んでください。 AUTO ackmodeの場合、コンテナは、リスナーが正常に戻るときにメッセージを確認します。