147.4. 예정된 Poll Consumer

이 구성 요소는 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");
}

147.4.1. Hipchat 사용자가 설정한 메시지 헤더

header상수유형설명

HipchatFromUser

HipchatConstants.FROM_USER

문자열

본문에는 이 사용자로부터 authToken 소유자로 전송된 메시지가 있습니다.

HipchatMessageDate

HipchatConstants.MESSAGE_DATE

문자열

날짜 메시지가 전송되었습니다. 형식은 Hipchat 응답에 있는 ISO-8601입니다.