package Ġio . piv otal . pal . data . framework . event Ċ Ċ import Ġjava . util . concurrent . BlockingQueue Ċ Ċ open Ġclass ĠDefault Async Event Publisher < T >( eventName : ĠString ) Ġ: ĠAsync Event Channel ( eventName ), ĠAsync Event Publisher < T > Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġpublish ( event : ĠT ) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġqueues Ġ= Ġsuper . get Queues () ĊĊĠĠĠĠĠĠĠ Ġfor Ġ( queue Ġin Ġqueues ) Ġ{ ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ Suppress (" UN CHECK ED _ CAST ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ( queue Ġas ĠBlock ing Queue < T >). offer ( event ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ