35.2. 实施简单处理器
概述 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
这部分描述了如何实施一个简单的处理器,该处理器在将交换委派到路由中的下一个处理器之前执行消息处理逻辑。
处理器接口 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
通过实施 org.apache.camel.Processor 接口来创建简单的处理器。如 例 35.2 “处理器接口” 所示,接口定义了一个方法 process ()
,它处理交换对象。
例 35.2. 处理器接口
package org.apache.camel; public interface Processor { void process(Exchange exchange) throws Exception; }
package org.apache.camel;
public interface Processor {
void process(Exchange exchange) throws Exception;
}
实施处理器接口 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
要创建简单的处理器,您必须实施 Processor 接口,并为 process ()
方法提供逻辑。例 35.3 “简单处理器实施” 显示简单处理器实施的概述。
例 35.3. 简单处理器实施
在交换对象委派到链中下一处理器 之前,执行 process ()
方法中的所有代码。
有关如何访问简单处理器中的消息正文和标头值的示例,请参考 第 35.3 节 “访问消息内容”。
将简单的处理器插入到路由中 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
使用 process ()
DSL 命令将简单的处理器插入到路由中。创建自定义处理器实例,然后将这个实例作为参数传递给 process ()
方法,如下所示:
org.apache.camel.Processor myProc = new MyProcessor(); from("SourceURL").process(myProc).to("TargetURL");
org.apache.camel.Processor myProc = new MyProcessor();
from("SourceURL").process(myProc).to("TargetURL");