스프링 통합 : 대기열에서 소비되지 않은 메시지를 읽는 방법?

Question

대기열 채널에서 사용되지 않은 메시지를 읽으려고합니다. 그러나 그것을 할 방법을 찾지 못했습니다. 가능한가? 그렇다면 적절한 문서를 가리 키십시오.

목적은 클라이언트가 UI에서 보류중인 항목을 볼 수 있도록 API를 노출하는 것입니다.

@MessageEndpoint(value = "jobQueuer") 
public class JobStartupQueuer { 

    @Resource 
    private Queue<Message> jobChannelQueue; 

    public boolean accept(Message<?> message) { 
     LOG.info("Channel size: {}", jobChannelQueue.size()); 
     return true; 
    } 
} 

을 따라서 jobChannelQueue이 당신의 ServiceActivator에 있도록 주입됩니다 : 당신이 메시지와 함께 원하는대로 당신은 단순히 당신의 ServiceActivator 중 하나의 "큐 채널"을 참조하고 할 수

Answer 1

감사합니다, 처리 방법 (예 : accept)을 사용하여 큐와 내부 메시지를 참조 할 수 있습니다.