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

273.6. 将数据发送到 Camel

当外部库需要将事件推送到 Camel 路由时，必须将 Reactive Streams 端点设置为消费者。 

from("reactive-streams:elements")
.to("log:INFO");
Copy to Clipboard Toggle word wrap

对 元素 流的句柄可以从 CamelReactiveStreams 实用程序类获取。 

CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);

Subscriber<String> elements = camel.streamSubscriber("elements", String.class);
Copy to Clipboard Toggle word wrap

订阅者可用于将事件推送到来自 元素 流的 Camel 路由。

以下是如何将它与 RxJava 2 搭配使用的示例（尽管可以使用任何被动框架发布事件）。 

Flowable.interval(1, TimeUnit.SECONDS)
    .map(i -> "Item " + i)
    .subscribe(elements);
Copy to Clipboard Toggle word wrap

字符串项在示例中由 RxJava 每秒生成，它们被推送到上述定义的 Camel 路由中。

273.6.1. 使用直接 API 将数据发送到 Camel
复制链接

另外，在这种情况下，可以使用直接 API 从端点 URI 获取 Camel 订阅者。 

CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);

// Send two strings to the "seda:queue" endpoint
Flowable.just("hello", "world")
    .subscribe(camel.subscriber("seda:queue", String.class));
Copy to Clipboard Toggle word wrap
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat