publish

abstract fun publish(topic: String, message: String)

abstract fun <T> publish(topic: String, serializer: KSerializer<T>, value: T)