MessageBroker

Types

abstract fun createTopic(topic: String, pCount: Int)

abstract fun <KC : Any, VC : Any> publish(topic: String, msdData: BrokerMsg<KC, VC>)

abstract fun <KC : Any, VC : Any> publishAll(topic: String, records: List<BrokerMsg<KC, VC>>)

abstract fun ~~publishAllOld~~(topic: String, records: List<Pair<K?, V>>)

abstract fun ~~publishOld~~(topic: String, key: K?, message: V)

abstract fun <KC : Any, VC : Any> subscribeAll(topic: String, keyClass: Class<KC>, valueClass: Class<VC>, onReceive: subscribeCallback<KC, VC>)

inline fun <KC : Any, VC : Any> MessageBroker<*, *>.subscribeAll(topic: String, noinline onReceive: subscribeCallback<KC, VC>)

abstract fun ~~subscribeAllOld~~(topic: String, onReceive: (t: String, List<Pair<K?, V>>) -> Unit)

abstract fun <KC : Any, VC : Any> subscribeWithFilter(topic: String, keyClass: Class<KC>, valueClass: Class<VC>, filter: (KC, VC) -> Boolean, onReceive: subscribeCallback<KC, VC>)

inline fun <KC : Any, VC : Any> MessageBroker<*, *>.subscribeWithFilter(topic: String, noinline filter: (KC, VC) -> Boolean, noinline onReceive: subscribeCallback<KC, VC>)

abstract fun ~~subscribeWithFilterOld~~(topic: String, filter: (K?, V) -> Boolean, onReceive: (t: String, List<Pair<K?, V>>) -> Unit)

abstract fun unsubscribe()