35.2. 实施简单处理器


概述

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

处理器接口

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

例 35.2. 处理器接口

package org.apache.camel;

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

实施处理器接口

要创建简单的处理器,您必须实施 Processor 接口,并为 process () 方法提供逻辑。例 35.3 “简单处理器实现” 显示了简单处理器实施的概要。

例 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.
        ...
    }
}

在将 Exchange 对象委派给链中的下一个处理器 之前,首先执行 process () 方法中的所有代码。

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

将简单的处理器插入到路由中

使用 process () DSL 命令将简单的处理器插入到路由中。创建自定义处理器实例,然后将此实例作为参数传递给 process () 方法,如下所示:

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

from("SourceURL").process(myProc).to("TargetURL");
Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.