第 35 章 实现处理器

摘要

Apache Camel 允许您实施自定义处理器。然后，您可以将自定义处理器插入到路由中，以便在通过路由时对交换对象执行操作。

35.1. 处理模型

pipelining model

pipelining 模型 描述了处理器以 第 5.4 节 “pipes 和 Filters” 排列的方式。pipelining 是处理一系列端点（制作端点只是一个特殊类型处理器）的最常用方法。当处理器以这种方式排列时，交换的 In 和 Out 消息将按照 图 35.1 “pipelining Model” 所示进行处理。

图 35.1. pipelining Model

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);