package Ġde . ck th omas . smart . iot . camunda . listeners Ċ Ċ import Ġde . ck th omas . smart . iot . I ot Constants Ċ import Ġde . ck th omas . smart . iot . log For Ċ import Ġorg . camunda . bpm . engine . delegate . Delegate Execution Ċ import Ġorg . camunda . bpm . engine . delegate . Execution Listener Ċ import Ġorg . camunda . bpm . model . bpmn . instance . camunda . Cam unda Properties Ċ import Ġorg . camunda . bpm . model . xml . instance . Model Element Instance Ċ import Ġorg . slf 4 j . Logger Ċ Ċ /** Ċ Ġ* ĠAuthor : ĠChristian ĠThomas Ċ Ġ* ĠCreated Ġon : Ġ 2 8 . 0 9 . 2 0 2 1 Ċ Ġ* Ċ Ġ* ĠCheck Ġlicense Ġdetails Ġ@ Ġproject Ġroot Ċ Ġ*/ Ċ abstract Ġclass ĠAbstract Mqtt Execution Listener ( ĊĠĠĠ Ġlistener Class : ĠClass < out ĠAbstract Mqtt Execution Listener > Ċ ) Ġ: ĠExecution Listener Ġ{ ĊĊĠĠĠ Ġprivate Ġvar Ġsignal Name : ĠString ? Ġ= Ġnull ĊĠĠĠ Ġvar Ġsignal Ref : ĠString ? Ġ= Ġnull ĊĊĠĠĠ Ġprotected Ġval Ġlogger Ġ= Ġlog For ( listener Class ) ĊĊĠĠĠ Ġprotected Ġfun Ġget Signal Name ( execution : ĠDelegate Execution ): ĠString Ġ= ĊĠĠĠĠĠĠĠ Ġsignal Name Ġ?: Ġexecution . process Engine Services ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. repository Service ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. getB pmn Model Instance ( execution . process Definition Id ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. getModel Element ById < Model Element Instance >( signal Ref Ġ?: Ġthrow ĠNoSuch ElementException (" No Ġsignal Ref Ġis Ġgiven ! ")) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. getAttribute Value ( I ot Constants . Engine Listener . ELEM _ SIGNAL _ NAME ) ĊĊĠĠĠ Ġprotected Ġfun Ġget Result Variable Name ( execution : ĠDelegate Execution ): ĠString ? Ġ= ĊĠĠĠĠĠĠĠ Ġexecution . bpmn Model Element Instance ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. extension Elements ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. elements Query ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. filter ByType ( Cam unda Properties :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. single Result () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. camunda Properties . first OrNull Ġ{ Ġcam unda Property Ġ-> ĠI ot Constants . Engine Listener . EXT _ PROP _ RESULT _ VAR _ NAME Ġ== Ġcam unda Property . camunda Name Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠ Ġ? . camunda Value Ċ Ċ }