38.2. 如何实施组件

概述

本节概述了实施自定义 Apache Camel 组件所需的步骤。

您需要实施哪些接口?

在实施组件时,通常需要实施以下 Java 接口:

  • org.apache.camel.Component
  • org.apache.camel.Endpoint
  • org.apache.camel.Consumer
  • org.apache.camel.Producer

另外,也需要实施以下 Java 接口:

  • org.apache.camel.Exchange
  • org.apache.camel.Message

实施步骤

您通常实施自定义组件,如下所示:

  1. 实施组件接口 abrt- theA 组件对象充当端点工厂。您扩展 DefaultComponent 类,并实施 createEndpoint() 方法。

    请参阅 第 39 章 组件接口

  2. 实施 Endpoint 接口 10.10.10.2- theAn 端点代表由特定 URI 标识的资源。实施端点时采取的方法取决于消费者是否遵循 事件驱动的 模式、调度轮询 模式或 轮询 模式。 对于事件驱动的模式,通过扩展 DefaultEndpoint 类并实施以下方法来实现端点:

    • createProducer()
    • createConsumer()

      对于调度的轮询模式,通过扩展 ScheduledPollEndpoint 类并实施以下方法来实现端点:

    • createProducer()
    • createConsumer()

      对于轮询模式,通过扩展 DefaultPollingEndpoint 类并实施以下方法来实现端点:

    • createProducer()
    • createPollConsumer()

      请参阅 第 40 章 端点接口

  3. 根据您需要 实施 的模式(事件驱动的、调度轮询或轮询),实施消费者,实施使用者可能要实施以下几项不同的方法。消费者实施对于确定用于处理消息交换的线程模型而言也非常重要。

    请参阅 第 41.2 节 “实现使用者接口”

  4. 实施 Producer 接口 & gt;_<-jaxbTo 实施制作者,您要扩展 DefaultProducer 类并实施 process() 方法。

    请参阅 第 42 章 producer Interface

  5. (可选)实现 Exchange 或 Message 接口 的 Message 接口 the default implementations of Exchange and Message 可以直接使用,但偶尔,您可能会发现有必要自定义这些类型。

    请参阅 第 43 章 Exchange Interface第 44 章 消息接口

安装和配置组件

您可以使用以下方法之一安装自定义组件:

  • 将组件直接添加到 CamelContext - the CamelContext.addComponent() 方法,以编程方式添加组件。
  • 使用 Spring 配置 IFL-The standard Spring bean 元素创建组件实例,添加 组件实例。bean 的 id 属性隐式地定义组件前缀。详情请查看 第 38.3.2 节 “配置组件”
  • 将 Apache Camel 配置为自动发现组件 KUBECONFIG -abrtAuto-discovery,确保 Apache Camel 根据需要自动加载组件。详情请查看 第 38.3.1 节 “设置 Auto-Discovery”