不读取所有邮件都在收件箱中使用多个MailID用于IntegrationFlows .from（邮件）

Question

即使我将调度程序池大小配置为5，有时它没有在收件箱中读取所有邮件。

@Bean
public IntegrationFlow customerCareMailFlow() {
    return IntegrationFlows.from(Mail
        .imapInboundAdapter("imap://" + property.getCustomerCareUserName() + ":"
            + property.getCustomerCarePassword() + "@" + property.getHost() + ":"
            + property.getPort() + "/INBOX")
                .searchTermStrategy(this::generateSearchTerm).shouldMarkMessagesAsRead(true)
                .userFlag("testSIUserFlag").simpleContent(true)
                .javaMailProperties(p -> p.put(property.getMailDebugKey(), property.getMailDebugValue())
                .put(property.getMailImapSSLEnableKey(), property.getMailImapSSLEnableValue())),
                e -> e.autoStartup(true).poller(p -> p.fixedRate(1000)))
                    .channel(MessageChannels.queue(property.getCustomerCareChannelName()))
    .get();
}

@Bean
public IntegrationFlow serviceDeskMailFlow() {
    return IntegrationFlows
        .from(Mail.imapInboundAdapter(
            "imap://" + property.getServiceDeskUserName() + ":" + property.getServiceDeskPassword()
                + "@" + property.getHost() + ":" + property.getPort() + "/INBOX")
                .searchTermStrategy(this::generateSearchTerm).shouldMarkMessagesAsRead(true)
                .userFlag("testSIUserFlag").simpleContent(true)
                .javaMailProperties(p -> p.put(property.getMailDebugKey(), property.getMailDebugValue())
                .put(property.getMailImapSSLEnableKey(), property.getMailImapSSLEnableValue())),
            e -> e.autoStartup(true).poller(p -> p.fixedRate(1000)))
                .log(e -> e.getPayload())
                .channel(MessageChannels.queue(property.getServiceDeskChannelName()))
    .get();
}

Answer 1

如果您已经有一个入站通道适配器，则没有理由使用Queuechannel。另外：考虑使用imapidleadapter（）。调度程序池中的这些5仍然不够：仅仅因为您有太多基于调度程序的任务：入站通道适配器和队列通道。