redis - 如何在运行时在springxd中获取 channel 名称

Question

我有一个流定义为 stream create --name foo --definition samplesource | sample 处理器 | sample 槽——部署。我将 Redis 用作 MessageBus。

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

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

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

提前致谢

Answer 1

I'm writing code...

该代码将在哪里运行？

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

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