MessageBroker

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
abstract fun createTopic(topic: String, pCount: Int)
Link copied to clipboard
abstract fun getStatus(): Map<String, Map<String, Any>>
Link copied to clipboard
abstract fun isBrokerAvailable(): Boolean
Link copied to clipboard
abstract fun <KC : Any, VC : Any> publish(topic: String, msdData: BrokerMsg<KC, VC>)
Link copied to clipboard
abstract fun <KC : Any, VC : Any> publishAll(topic: String, records: List<BrokerMsg<KC, VC>>)
Link copied to clipboard
abstract fun publishAllOld(topic: String, records: List<Pair<K?, V>>)
Link copied to clipboard
abstract fun publishOld(topic: String, key: K?, message: V)
Link copied to clipboard
abstract fun <KC : Any, VC : Any> subscribeAll(topic: String, keyClass: Class<KC>, valueClass: Class<VC>, onReceive: subscribeCallback<KC, VC>)
Link copied to clipboard
inline fun <KC : Any, VC : Any> MessageBroker<*, *>.subscribeAll(topic: String, noinline onReceive: subscribeCallback<KC, VC>)
Link copied to clipboard
abstract fun subscribeAllOld(topic: String, onReceive: (t: String, List<Pair<K?, V>>) -> Unit)
Link copied to clipboard
abstract fun <KC : Any, VC : Any> subscribeWithFilter(topic: String, keyClass: Class<KC>, valueClass: Class<VC>, filter: (KC, VC) -> Boolean, onReceive: subscribeCallback<KC, VC>)
Link copied to clipboard
inline fun <KC : Any, VC : Any> MessageBroker<*, *>.subscribeWithFilter(topic: String, noinline filter: (KC, VC) -> Boolean, noinline onReceive: subscribeCallback<KC, VC>)
Link copied to clipboard
abstract fun subscribeWithFilterOld(topic: String, filter: (K?, V) -> Boolean, onReceive: (t: String, List<Pair<K?, V>>) -> Unit)
Link copied to clipboard
abstract fun unsubscribe()