使用camel-mail-starter 3.12.0遭遇Exchange.getMessage()方法调用歧义异常

核心问题分析 #

出现AmbiguousMethodCallException的原因有两个，同时还有一处潜在的类型转换问题：

1. 路由表达式方法歧义：路由中的${exchange.message}表达式，Camel解析时无法确定调用Exchange.getMessage()的无参重载还是带Class参数的重载，触发方法匹配歧义。
2. Processor代码调用错误：exchange.getIn(MailMessage.class)是无效语法，Exchange.getIn()没有带Class参数的重载，无法直接指定类型获取入站消息。
3. 潜在类型转换异常：当前使用POP3协议，但代码强制将原始消息转为IMAPMessage，运行时会触发类型转换错误。

具体修正步骤 #

1. 修正路由配置 #

将歧义的${exchange.message}替换为明确的表达式，比如直接获取入站消息体：

RouteBuilder emailListener = new RouteBuilder () {
    @Override
    public void configure() throws Exception {
        from (from)
            .process (new EmailProcessor (body, client))
            .log("${exchange.in.body}"); // 替换原有的${exchange.message}
    }
};

或者显式调用无参的getMessage()方法：

.log("${exchange.getMessage()}");

2. 修正Processor代码 #

import org.apache.camel.Processor;
import org.apache.camel.Exchange;
import org.apache.camel.component.mail.MailMessage;
import org.apache.commons.mail.util.MimeMessageParser;
import javax.mail.MimeMessage;

public class EmailProcessor implements Processor {
    private final Object body;
    private final Client client;

    public EmailProcessor(Object body, Client client) {
        this.body = body;
        this.client = client;
    }

    @Override
    public void process(Exchange exchange) throws Exception {
        // 修正获取MailMessage的方式
        MailMessage message = exchange.getIn().getBody(MailMessage.class);
        // 替换IMAPMessage为通用的MimeMessage，适配POP3协议
        MimeMessageParser parser = new MimeMessageParser((MimeMessage) message.getOriginalMessage());

        try {
            parser.parse();
            // 这里可添加邮件解析后的业务逻辑，如读取标题、内容、附件等
        } catch (Exception e) {
            ApplicationException applicationException = new ApplicationException(
                e.getStackTrace(), 
                Collections.singletonMap("process", " Inside camel mail"), 
                getClass(), "33"
            );
            applicationException.notifyViaEmail();
        }
    }
}

关键说明 #

• 必须确保EmailProcessor实现org.apache.camel.Processor接口，否则Camel会将其视为普通Bean，可能引发更多方法匹配问题。
• 使用MimeMessage作为原始消息的转换类型，可同时兼容POP3和IMAP协议，避免协议切换时的类型错误。

内容的提问来源于stack exchange，提问作者Amit Mishra