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

Question

我有一个流定义为流create --name foo --definition samplesource | sampleprocessor | samplesink --deploy。我使用Redis作为MessageBus。

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

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

我们可以随时获得频道名称吗？

在此先感谢

Answer 1

我在写代码...

哪里该代码将运行？

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

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