Apache Camel pollEnrich仅返回单封邮件问题求助（Gmail IMAP）

问题根源 #

Camel的IMAP Consumer在一次poll中会为每封邮件生成独立的Exchange，但pollEnrich默认仅等待并聚合第一个到达的Exchange就结束enrichment流程，后续的邮件Exchange不会被传入聚合策略，导致最终集合里只有单封邮件。

解决方案 #

需要调整pollEnrich的参数，让它等待当前poll周期内所有邮件都处理完成后再完成聚合，同时确保聚合策略能正确累积所有邮件：

1. 配置pollEnrich的关键参数 #

• 设置timeout为足够长的数值（比如3000毫秒），确保所有邮件能在超时前被Consumer处理并发送到聚合器
• 开启aggregateOnCompletion=true，告知pollEnrich要等当前poll的所有Exchange处理完成后才结束聚合

2. 优化聚合策略 #

设置初始空集合作为聚合起点，避免原消息内容干扰邮件的累积逻辑。

修改后的路由代码示例 #

...
.pollEnrich()
    .simple("""
        imap://${exchangeProperty.imapEndpoint}
        ?delay=0
        &initialDelay=0
        &additionalJavaMailProperties=#bean:${exchangeProperty.imapAdditionalPropertiesName}
        &bridgeErrorHandler=true&disconnect=false
        &closeFolder=false
        &delete=${exchangeProperty.imapDelete}
        &unseen=true
        &maxMessagesPerPoll=-1
        &username=RAW(${exchangeProperty.imapUsername})
        &password=RAW(${exchangeProperty.imapPassword})
        """)
    // 配置等待超时和完成时聚合
    .timeout(3000)
    .aggregateOnCompletion(true)
    .aggregationStrategy(
        AggregationStrategies.flexible()
            // 初始值设为空HashSet，避免原消息干扰
            .initial(() -> new HashSet<>())
            .pick(ExpressionBuilder.messageExpression())
            .condition(Objects::nonNull)
            .accumulateInCollection(HashSet.class)
            .storeInBody()
    )
.end()
.process(imapProcessor)
.end();

额外检查项 #

• 确认Gmail IMAP设置中已开启“启用IMAP”选项，无特殊邮件数量限制
• 验证maxMessagesPerPoll=-1是否生效：若仍有数量限制，可尝试替换为较大的具体数值（比如100）

内容的提问来源于stack exchange，提问作者Kiril Nugmanov