148.4. 예약된 Poll 소비자

이 구성 요소는 ScheduledPollConsumer를 구현합니다. 제공된 'consumeUsers'의 마지막 메시지만 검색되고 교환 본문으로 전송됩니다. 다음 폴링에 새 메시지가 없을 때 동일한 메시지를 다시 검색하지 않으려면 아래 표시된 것처럼 멱등 소비자를 추가할 수 있습니다. ScheduledPollConsumer의 모든 옵션을 사용하여 소비자를 더 많이 제어할 수도 있습니다.

@Override
public void configure() throws Exception {
 String hipchatEndpointUri = "hipchat://?authToken=XXXX&consumeUsers=@Joe,@John";
 from(hipchatEndpointUri)
  .idempotentConsumer(
    simple("${in.header.HipchatMessageDate} ${in.header.HipchatFromUser}"),
    MemoryIdempotentRepository.memoryIdempotentRepository(200)
  )
  .to("mock:result");
}