148.4. Scheduled 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");
}
148.4.1. Hipchat consumer 设置的消息标头 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
| 标头 | 常数 | 类型 | 描述 |
|---|---|---|---|
| HipchatFromUser | HipchatConstants.FROM_USER | 字符串 | 正文包含从此用户发送到 authToken 的所有者的消息 |
| HipchatMessageDate | HipchatConstants.MESSAGE_DATE | 字符串 | 发送的日期消息。格式为 ISO-8601,如 Hipchat 响应 中所示。 |