package Ġdev . al pas . queue Ċ Ċ import Ġdev . al pas . Config Ċ import Ġdev . al pas . Container Ċ import Ġdev . al pas . Environment Ċ Ċ @ Suppress (" unused ") Ċ open Ġclass ĠQueue Config ( env : ĠEnvironment ) Ġ: ĠConfig Ġ{ ĊĠĠĠ Ġprivate Ġval Ġconnections Ġ= Ġmutable Map Of < String , ĠLazy < Queue Connection >>() ĊĠĠĠ Ġopen Ġval Ġdefault Connection Ġ= Ġenv (" QUEUE _ CONNECTION ", Ġ" activ emq ") ĊĊĠĠĠ Ġfun Ġadd Connection ( key : ĠString , Ġconnection : ĠLazy < Queue Connection >) Ġ{ ĊĠĠĠĠĠĠĠ Ġconnections [ key ] Ġ= Ġconnection ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġconnection ( container : ĠContainer , Ġname : ĠString ? Ġ= Ġnull ): ĠQueue Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġconnection Name Ġ= Ġname Ġ?: Ġdefault Connection ĊĠĠĠĠĠĠĠ Ġreturn Ġconnections [ connection Name ]?. value ?. connect ( container ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ?: Ġthrow ĠException (" Unsupported Ġqueue Ġconnection : Ġ'$ connection Name '. ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġinternal Ġfun Ġregistered Connection Names (): ĠList < String > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġconnections . keys . toList () ĊĠĠĠ Ġ} Ċ } Ċ