Apache骆驼：Pollenrich不称呼动态URI

Question

我有一条轮询服务器电子邮件的路线。在fornctROute中，我正在尝试通过emailpollingRoute中的Pollenrich方法通过IMAP协议来传递电子邮件的主题。目前，我面临着动态URI端点的问题。我注意到在调用Pollenrich方法之前正在清除标头。因此，我尝试使用$ {ExchangeProperty.Subject}，但没有发送电子邮件。当我直接将主题设置为字符串中的端点时，然后将获取电子邮件。

如何在Pollenrich方法中动态设置主题？该主题正在从farnerroute传递给emailPollingRoute路由。

感谢任何帮助

@Component
public class FunctionRoute extends EmailPollingRoute {
    
    static final Logger LOGGER = LoggerFactory.getLogger(FunctionRoute.class);
    
    
    @Override
    public void configure() throws Exception {
        from("direct:process_polling_email_function")
        .process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                subject = "ABCD - Test1";
                exchange.setProperty("ABCD - Test1");
                LOGGER.info("1. subject - " + subject);
                
            }})                          
        //.setProperty("subject", constant("ABCD - Test1"))
        //.setHeader("subject", simple("ABCD - Test1"))
        .to("direct:process_polling_email");
    }

}

@Component
public class EmailPollingRoute extends BaseRouteBuilder {
    
    static final Logger LOGGER = LoggerFactory.getLogger(EmailPollingRoute.class);
        
    public String subject;
    
    @Override
    public void configure() throws Exception {
            
        //super.configure();
        //2362
    
        //@formatter:off
        from("direct:process_polling_email")
            .routeId("routeId_EmailPollingRoute")
            .process(new Processor() {
                @Override
                public void process(Exchange exchange) throws Exception {
                
                     subject = exchange.getProperty("subject", String.class);
                     LOGGER.info("0001 - subjectB: (" + subject + ")");
                    
                }})
            
            .pollEnrich("imaps://XXXXXXX.info"
                    + "?username=XXXXX&"
                    + "password=XXXXXXX&"
                    +"folderName=Inbox/Test&"
                    +"searchTerm.fromSentDate=now-72h&"
                        +"searchTerm.subject=${exchangeProperty.subject}&"
                        +"fetchSize=1");
                    
            .to("log:newmail");
            
            //@formatter:on
        
    }
}

Answer 1

您可以使用简单方法动态设置Pollenrich URI，也可以以相似的方式指定超时。

.pollEnrich()
    .simple("imaps://XXXXXXX.info"
        + "?username=XXXXX&"
        + "password=XXXXXXX&"
        +"folderName=Inbox/Test&"
        +"searchTerm.fromSentDate=now-72h&"
        +"searchTerm.subject=${exchangeProperty.subject}&"
        +"fetchSize=1")
    .timeout(1000);