broker/ru.sydis.broker.implementations

Package-level declarations

Types

object GlobalNumber

Глобальный счетчик сообщений

KafkaMessageBroker

class KafkaMessageBroker<K : Any, V : Any>(consumerProps: Map<String, Any>? = null, producerProps: Map<String, Any>? = null, keyClass: Class<K>, valClass: Class<V>, needSubscribe: Boolean = true) : MessageBroker<K, V>

NatsMessageBroker

class NatsMessageBroker<K : Any, V : Any>(connection: Connection, keyClass: Class<K>, valClass: Class<V>, topicPartitionMap: Map<String, Pair<Int, String>> = emptyMap(), brokerId: String = "defaultBroker") : MessageBroker<K, V>

class SendReceive