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