148.4. 调度的 Poll Consumer

这个组件实现了 ScheduledPollConsumer。只有提供的 'consumeUsers' 的最后一个消息才会检索并作为 Exchange body 发送。如果您不希望在下一次轮询上没有新消息时再次检索相同的消息，您可以添加幂等的消费者，如下所示。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");
}