RabbitTemplate получать сообщения и запросы

Question

Мой вопрос очень похож на этот: RabbitTemplate receive and requeue К сожалению, он был отмечен как ответ, хотя ответ не соответствует моим потребностям.

Я хочу подражать функциональности интерфейса администратора Rabbit Admin, то есть хочу синхронно читать сообщения из очереди, но не хочу, чтобы очередь их потеряла, то есть что-то вроде просмотра.

Ответ здесь RabbitTemplate receive and requeue предлагает использовать прослушиватель, но в этом случае он будет читать и запрашивать бесконечно. Я хочу получить и запросить сообщения только один раз, поэтому, я думаю, я должен использовать RabbitTemplate, а не слушатель.

Answer 1

class Peeker implements ChannelCallback<Message> { 

    final MessagePropertiesConverter propertiesConverter = new DefaultMessagePropertiesConverter(); 

    @Override 
    public Message doInRabbit(Channel channel) throws Exception { 
     GetResponse result = channel.basicGet("someQ", false); 
     if (result == null) { 
      return null; 
     } 
     channel.basicReject(result.getEnvelope().getDeliveryTag(), true); 
     return new Message(result.getBody(), propertiesConverter.toMessageProperties(
       result.getProps(), result.getEnvelope(), "UTF-8")); 
    } 
} 
Peeker peeker = new Peeker(); 


... 


Message peek = this.rabbitTemplate.execute(peeker);