wie Kanalnamen zur Laufzeit in springxd bekommen

Question

ich einen Strom als Strom definiert haben erstellen --name foo --definition samplesource | Sampleprozessor | Beispielverbindung --deploy Ich benutze Redis als MessageBus.

Wenn sampleprocessor oder samplesink ausgefallen ist, dann wird xd schieben failed Meldungen zu Redis in Fehler: foo.n Warteschlange. Ich schreibe Code, um die Nachrichten von Fehlerwarteschlange zu foo.n zu bringen.

Herausforderung hier ist, ich will nicht den Stream-Namen in meinem Code codieren, wie dieses Stück über all meine xd Module gehandhabt wird.

Können wir den Kanalnamen on the fly?

Dank im Voraus

Answer 1

I-Code ich schreibe ...

Wo ist, dass Code ausgeführt zu gehen?

Wenn es innerhalb eines Moduls in dem Strom ist, Modul-Metadaten über die Anwendungskontext Umgebung Eigenschaften zur Verfügung:

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