publish

open override fun publish(topic: String, message: String)

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