Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

60.10. CDI 事件端点

从 Camel 2.17 开始提供

CDI 事件端点通过 Camel 路由 桥接 CDI 事件，以便可以从 Camel 用户（由 Camel 生成者resp.）无缝观察到被使用的/消耗（由 Camel 生成者生成 / fired）。

Camel CDI 提供的 CdiEventEndpoint<T > bean 可用于观察 / 使用 事件类型 为 T 的 CDI 事件，例如： 

@Inject
CdiEventEndpoint<String> cdiEventEndpoint;

from(cdiEventEndpoint).log("CDI event received: ${body}");
Copy to Clipboard Toggle word wrap

这等同于编写： 

@Inject
@Uri("direct:event")
ProducerTemplate producer;

void observeCdiEvents(@Observes String event) {
    producer.sendBody(event);
}

from("direct:event").log("CDI event received: ${body}");
Copy to Clipboard Toggle word wrap

相反，CdiEventEndpoint<T > bean 可以用来生成 / 触发 事件类型 为 T 的 CDI 事件，例如： 

@Inject
CdiEventEndpoint<String> cdiEventEndpoint;

from("direct:event").to(cdiEventEndpoint).log("CDI event sent: ${body}");
Copy to Clipboard Toggle word wrap

这等同于编写： 

@Inject
Event<String> event;

from("direct:event").process(new Processor() {
    @Override
    public void process(Exchange exchange) {
        event.fire(exchange.getBody(String.class));
    }
}).log("CDI event sent: ${body}");
Copy to Clipboard Toggle word wrap

或使用 Java 8 lambda 表达式： 

@Inject
Event<String> event;

from("direct:event")
    .process(exchange -> event.fire(exchange.getIn().getBody(String.class)))
    .log("CDI event sent: ${body}");
Copy to Clipboard Toggle word wrap

特定 CdiEventEndpoint< T > 注入点的 type 变量 T （代表限定符）会自动转换为参数化事件类型 (resp. 到 事件限定符)例如： 

@Inject
@FooQualifier
CdiEventEndpoint<List<String>> cdiEventEndpoint;

from("direct:event").to(cdiEventEndpoint);

void observeCdiEvents(@Observes @FooQualifier List<String> event) {
    logger.info("CDI event: {}", event);
}
Copy to Clipboard Toggle word wrap

当 CDI 容器中存在多个 Camel 上下文时，Camel 上下文 bean 限定符（如 @ContextName ）可用于验证 CdiEventEndpoint<T& gt; 注入点，例如： 

@Inject
@ContextName("foo")
CdiEventEndpoint<List<String>> cdiEventEndpoint;
// Only observes / consumes events having the @ContextName("foo") qualifier
from(cdiEventEndpoint).log("Camel context (foo) > CDI event received: ${body}");
// Produces / fires events with the @ContextName("foo") qualifier
from("...").to(cdiEventEndpoint);

void observeCdiEvents(@Observes @ContextName("foo") List<String> event) {
    logger.info("Camel context (foo) > CDI event: {}", event);
}
Copy to Clipboard Toggle word wrap

请注意，CDI 事件 Camel 端点会动态地为 事件类型 和事件 限定符 组合添加  观察方法 ，并且只依赖于容器类型safe observer 解析，这会导致尽可能有效地实施。

此外，作为 CDI 类型安全 性质和 Camel 组件 模型的动态性质之间的缺陷非常高，因此无法通过 URI 创建 CDI 事件 Camel 端点的实例。 实际上，CDI 事件组件的 URI 格式为： 

cdi-event://PayloadType<T1,...,Tn>[?qualifiers=QualifierType1[,...[,QualifierTypeN]...]]
Copy to Clipboard Toggle word wrap

使用授权 PayloadType (resp. the QualifierType)是 URI 转义有效负载(resp. qualifier) raw 类型，后跟一个 type 参数部分来表示 payload 参数ized 类型。这会导致 不友好的 URI，例如： 

cdi-event://org.apache.camel.cdi.example.EventPayload%3Cjava.lang.Integer%3E?qualifiers=org.apache.camel.cdi.example.FooQualifier%2Corg.apache.camel.cdi.example.BarQualifier
Copy to Clipboard Toggle word wrap

但是，从根本上讲，这会防止端点实例和观察器方法之间有效绑定，因为 CDI 容器在部署阶段没有发现 Camel 上下文模型的方法。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat