第 35 章 实施处理器
摘要
Apache Camel 允许您实施自定义处理器。然后,您可以将自定义处理器插入到路由中,以便在通过路由时对交换对象执行操作。
35.1. 处理模型
pipelining model
pipelining 模型 描述了处理器在 第 5.4 节 “管道和过滤器” 中采用的方法。pipelining 是处理一系列端点(生产端点只是特殊的处理器类型)的最常用方法。当处理器采用这种方式时,交换的 In 和 Out 信息将处理,如 图 35.1 “pipelining Model” 所示。
图 35.1. pipelining Model
管道中的处理器看起来类似于服务,其中 In 消息与请求类似,而 Out 消息类似于回复。实际上,在现实管道中,管道中的节点通常由 Web 服务端点实施,如 CXF 组件。
例如,例 35.1 “Java DSL 管道” 显示从由两个处理器、ProcessorA
、ProcessorB
和一个制作者端点 TargetURI 组成的 Java DSL 管道。
例 35.1. Java DSL 管道
from(SourceURI).pipeline(ProcessorA, ProcessorB, TargetURI);