139.3. スケジュールされたポーリングコンシューマー

このコンポーネントは ScheduledPollConsumer を実装します。指定された 'consumeUsers' の最後のメッセージのみが取得され、Exchange ボディーとして送信されます。次のポーリングに新しいメッセージがない場合に同じメッセージを再度取得しない場合は、以下のようにべき等コンシューマーを追加できます。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");
}