RabbitMQ + Spring 통합. 큐 크기 1 만 삭제하면 내가 지금 가망 경우 RabbitMQ와 Spring 통합이 아이디어를 구현하고자하는

Question

재정의 :

1. 한 큐, 1 메시지 capatity와.
2. 소비자가이 메시지를 요청할 것입니다. 대기열에 있으면 메시지가 전달되고 그렇지 않으면 null 또는 오류가 발생합니다.
3. 이 메시지 (대기열에있는 경우)는 다운로드 된 것으로 삭제되지 않으며 생산자가 다른 새 메시지를 대기열에 넣었을 때만 삭제됩니다.

감사합니다. 이 같은

Answer 1

뭔가 :

@Transactional 
public Message getMessageFromQueue(String queue) { 
    try { 
     return this.rabbitTemplate.receive(queue); 
    } 
    finally { 
     TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); 
    } 
} 

트랜잭션 범위와 우리는 트랜잭션 내에서 큐를 폴링합니다. setRollbackOnly()을 사용하면 TX를 rallback하여 메시지를 대기열로 되돌려 보냅니다.