35.2. 实施简单处理器

这部分描述了如何实施一个简单的处理器，该处理器在将交换委派到路由中的下一个处理器之前执行消息处理逻辑。

通过实施 org.apache.camel.Processor 接口来创建简单的处理器。如 例 35.2 “处理器接口” 所示，接口定义了一个方法 process （），它处理交换对象。

package org.apache.camel;

public interface Processor {
    void process(Exchange exchange) throws Exception;
}

要创建简单的处理器，您必须实施 Processor 接口，并为 process （） 方法提供逻辑。例 35.3 “简单处理器实施” 显示简单处理器实施的概述。

import org.apache.camel.Processor;

public class MyProcessor implements Processor {
    public MyProcessor() { }

    public void process(Exchange exchange) throws Exception
    {
        // Insert code that gets executed *before* delegating
        // to the next processor in the chain.
        ...
    }
}

在交换对象委派到链中下一处理器 之前，执行 process （） 方法中的所有代码。

有关如何访问简单处理器中的消息正文和标头值的示例，请参考 第 35.3 节 “访问消息内容”。

使用 process （） DSL 命令将简单的处理器插入到路由中。创建自定义处理器实例，然后将这个实例作为参数传递给 process （） 方法，如下所示：

org.apache.camel.Processor myProc = new MyProcessor();

from("SourceURL").process(myProc).to("TargetURL");