package Ġcom . r 3 . logic apps Ċ Ċ import Ġcom . r 3 . logic apps . service bus . Service bus Client Tests . Companion . FROM _ C ORD A _ QUEUE Ċ import Ġcom . r 3 . logic apps . service bus . Service bus Client Tests . Companion . SERVICE _ BUS Ċ import Ġcom . r 3 . logic apps . service bus . Service bus Client Tests . Companion . TO _ C ORD A _ QUEUE Ċ import Ġnet . cord a . core . identity . C ord a X 5 0 0 Name Ċ import Ġnet . cord a . core . utilities . get OrThrow Ċ import Ġnet . cord a . testing . core . Test Identity Ċ import Ġnet . cord a . testing . driver . Driver DSL Ċ import Ġnet . cord a . testing . driver . Driver Parameters Ċ import Ġnet . cord a . testing . driver . driver Ċ import Ġnet . cord a . testing . node . Test C ord app Ċ Ċ abstract Ġclass ĠTest Base Ġ{ ĊĠĠĠ Ġprotected Ġfun ĠString . to Identity () Ġ= ĠTest Identity ( C ord a X 5 0 0 Name ( this , Ġ"", Ġ" GB ")) ĊĊĠĠĠ Ġprotected Ġfun Ġwith Driver ( block : ĠDriver DSL . () Ġ-> ĠUnit ) Ġ= Ġdriver ( ĊĠĠĠĠĠĠĠ ĠDriver Parameters ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġc ord apps ForAll Nodes Ġ= ĠlistOf ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠTest C ord app . find C ord app (" com . r 3 . logic apps "). with Config ( map Of ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" connectionString " Ġto ĠSERVICE _ BUS , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" inbound Queue " Ġto ĠTO _ C ORD A _ QUEUE , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" outbound Queue " Ġto ĠFROM _ C ORD A _ QUEUE ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġis Debug Ġ= Ġtrue , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġstart Nodes In Process Ġ= Ġtrue ĊĠĠĠĠĠĠĠ Ġ), Ġblock ĊĠĠĠ Ġ) ĊĊĠĠĠ Ġprotected Ġfun ĠDriver DSL . start Nodes ( var arg Ġident ities : ĠTest Identity ) Ġ= Ġident ities ĊĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġstart Node ( provided Name Ġ= Ġit . name ). get OrThrow () Ġ} Ċ }