subscribeTopic

open suspend override fun subscribeTopic(topic: String)