如何在springxd运行时获取频道名称

Question

我有一个流定义为 stream create --name foo --definition samplesource |样品处理器 |样品池——部署。我使用 Redis 作为 MessageBus。

如果 sampleprocessor 或 samplesink 失败，则 xd 会将失败的消息推送到 Redis 到 ERRORS:foo.n 队列中。我正在编写代码将消息从错误队列带到 foo.n。

这里的挑战是我不想在我的代码中硬编码流名称，因为这部分是在我所有的 xd 模块中处理的。

我们可以即时获取频道名称吗？

提前致谢

Answer 1

我在写代码……

该代码将在哪里运行？

如果它位于流中的模块内，则模块元数据可通过应用程序上下文环境属性获得：

    ${xd.group.name}
    ${xd.module.label}
    ${xd.module.type}
    ${xd.module.sequence}