broker/ru.sydis.broker.interfaces/MessageBroker/Companion

Companion

object Companion

Properties

CHUNK_INDEX_TAG

const val CHUNK_INDEX_TAG: String

Тег для хранения индекса чанка в сообщении

val CHUNK_SIZE: Int

Размер чанка, если сообщение не умещается в один пакет брокера

COMPRESSION_TYPE_TAG

const val COMPRESSION_TYPE_TAG: String

const val KEY_TAG: String

Тег для хранения ключа в сообщении

TOTAL_CHUNKS_TAG

const val TOTAL_CHUNKS_TAG: String

Тег для хранения общего количества чанков в сообщении

const val TS_TAG: String

Тег для хранения времени в сообщении

Functions

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

subscribeWithFilter

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