3.8. MicroProfile Reactive 消息传递管理
3.8.1. 为 JBoss EAP 配置所需的 MicroProfile 被动消息传递扩展和子系统
如果要启用 JBoss EAP 实例的异步被动消息传递,您必须通过 JBoss EAP 管理 CLI 添加其扩展。
先决条件
- 您添加了带有 SmallRye 扩展和子系统的 Reactive Streams Operator。如需更多信息,请参阅 MicroProfile Reactive Streams Operators Subsystem Configuration: Required Extension。
- 您添加了使用 SmallRye 扩展和子系统的 Reactive Messaging。
流程
- 打开 JBoss EAP 管理 CLI。
- 输入以下代码:
[standalone@localhost:9990 /] /extension=org.wildfly.extension.microprofile.reactive-messaging-smallrye:add {"outcome" => "success"} [standalone@localhost:9990 /] /subsystem=microprofile-reactive-messaging-smallrye:add { "outcome" => "success", "response-headers" => { "operation-requires-reload" => true, "process-state" => "reload-required" } }
注意
如果您使用 Galleon 在 OpenShift 上置备服务器,请确保包含 microprofile-reactive-messaging
Galleon 层来获取核心 MicroProfile 2.0.1 和被动消息传递功能,以及启用所需的子系统和扩展。请注意,此配置不包含启用 Kafka 连接器功能所需的 JBoss EAP 模块。为此,可使用 microprofile-reactive-messaging-kafka
层。
验证
如果您在管理 CLI 的两个位置中看到 成功
,则已成功为 JBoss EAP 添加了所需的 MicroProfile 被动消息传递扩展和子系统。
提示
如果生成的代码显示 reload-required
,您必须重新加载服务器配置以完全应用所有更改。要重新加载,请在单机服务器 CLI 中输入 reload
。