当前位置: 首页 > 知识库问答 >
问题:

骆驼:如何并行处理IMAP电子邮件?

姚嘉容
2023-03-14

我试图创建一个Camel路由,它将并行处理传入的IMAP消息。邮件组件应该将传入的邮件分发到不同的线程(但是每个消息都应该按顺序通过两个处理步骤)。

from("imap://...")
    .threads(4)
    .process(new FirstProcessor())
    .process(new SecondProcessor());

共有1个答案

韩智敏
2023-03-14

camel-mail使用者不支持这一点。它在使用者端使用相同的线程按顺序处理邮件。

您需要使用窃听或在无等待模式下将消息存储到seda队列中,等等。

 类似资料:
  • 我正在为IMAP服务器编程,但遇到了一个问题:电子邮件来自哪里? 我一直认为事件的基本过程是: 发送方客户端使用SMTP协议向SMTP服务器(主机A)发送电子邮件 这让我想知道:电子邮件是如何从接受SMTP的服务器发送到提供服务的IMAP服务器的?他们有协议吗?他们会把它放在目录里吗? 我见过目录的用法——每个用户有一个文件——它似乎不适合大型用户群。当两个进程同时读/写数据时,它不会也会引起问题

  • 我正在尝试从目录中选取一个文件,拆分一个文件,并将每一个拆分行添加到ActiveMQ中。我在这个过程中遇到了异常处理的问题。假设目录中的文件是一个二进制文件(可执行文件),那么splitter会显示org.apache.camel.runtimeCamelException和java.nio.charset.MalFormedInputException异常。如果出现这种情况,那么我需要捕获这些异

  • 问题内容: 我目前正在使用Python imaplib处理电子邮件文本。 我使用fetch命令从GMail服务器中提取原始数据电子邮件。但是,我发现一件事确实很棘手-等号’=’。它不是正常的等号,而是特殊符号。 例如: 有时’=’用作文本行末尾的连字符: u with preparatory work over the next few weeks. It would be wise to sta

  • 我一直试图获取电子邮件正文与imap_fetchbody($stream,$msgno,$选项),但没有成功。 然后我尝试使用imap_fetchstructure($stream,$msgno),并使用各自的子类型手动解码每种类型,如:- 对于前两个,我可以用这样的东西来解码 但说到混合,我要么不知道,要么我该怎么办,要么我在哪里犯错。

  • 如何在数据库中存储该电子邮件的唯一ID。 我尝试了$概述=imap_fetch_overview($inbox,$email_number,0);我收到了一堆数字,但问题是当其中一封电子邮件被删除时,数字会发生变化。 如何正确存储?MD5消息还是什么? 基本上,我试图在我的个人网络应用程序上接收电子邮件,在那里我可以管理和访问我自己的电子邮件。它使用imap调用gmail。 无论如何,我可以在哪里

  • 在camel spring ws中,有没有办法将自定义主体(例如自定义bean)和http状态返回为500? 我试过了 然后在processor公共类ExceptionProcessor实现processor{ } 但是即使身体是我想要的,超文本传输协议状态总是200。 你能帮我吗? 更多信息:我正在使用camel 2.20.2版