package Ġio . mic ronaut . jms . docs . configuration Ċ Ċ import Ġio . mic ronaut . context . annotation . Requires Ċ // Ġtag :: imports [] Ċ import Ġio . mic ronaut . context . event . Bean Created Event Ċ import Ġio . mic ronaut . context . event . Bean Created EventListener Ċ import Ġjak arta . inject . Singleton Ċ import Ġorg . apache . activ emq . Active MQ ConnectionFactory Ċ import Ġjavax . jms . ConnectionFactory Ċ // Ġend :: imports [] Ċ Ċ @ Requires ( property Ġ= Ġ" spec . name ", Ġvalue Ġ= Ġ" Custom ize Broker Spec ") Ċ // Ġtag :: clazz [] Ċ @ Singleton Ċ class ĠCustom ize Broker J MS Connection Pool Listener Ġ: ĠBean Created EventListener < ConnectionFactory ?> Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġon Created ( event : ĠBean Created Event < ConnectionFactory ?> ): ĠConnection Factory ? Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġconnection Factory Ġ= Ġevent . bean ĊĠĠĠĠĠĠĠ Ġif Ġ( connection Factory Ġis ĠActive MQ ConnectionFactory ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġconnection Factory . is Use Async Send Ġ= Ġtrue ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġreturn Ġconnection Factory ĊĠĠĠ Ġ} Ċ } Ċ // Ġend :: clazz [] Ċ