如何在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}