abstract class Msg : Serializable
class Bla : Msg
class Blubb : Msg

abstract class CrudDao<C>(sessionFactory: SessionFactory) : AbstractDAO<C>(sessionFactory)
class BlaDao : CrudDao<Bla>
class BlubbDao : CrudDao<Blubb>

fun <T : Msg> storeMsg(dao: CrudDao<T>, msg: T) {
  dao.persist(msg)
}

val daos = listOf(BlaDao(), BlubbDao())
val Broker = Broker({ msg : Msg -> 
  val dao = daos.filter(...).single()
  storeMsg(dao, msg)
})