NSL KV/xyz.noisif.nsl.kv.jedis.pubsub/BinaryJedisPubSubAdapter

BinaryJedisPubSubAdapter

open class BinaryJedisPubSubAdapter : BinaryJedisPubSub

Constructors

constructor(kvSubscriber: KvSubscriber<Array<Byte>>, paramExtractor: ChannelParamExtractor)

Properties

authenticator

private val authenticator: JedisSafeAuthenticator

kvSubscriber

private val kvSubscriber: KvSubscriber<Array<Byte>>

LOG

private val LOG: Logger

paramExtractor

private val paramExtractor: ChannelParamExtractor

pingResultHandler

private val pingResultHandler: Consumer<Any>

subscribedChannels

open val subscribedChannels: Int

Functions

encode

protected fun encode(raw: Array<Byte>): Array<Byte>

protected abstract fun encode(p: Array<Byte>): T

isSubscribed

fun isSubscribed(): Boolean

onMessage

open fun onMessage(channel: Array<Byte>, message: Array<Byte>)

onPMessage

open fun onPMessage(pattern: Array<Byte>, channel: Array<Byte>, message: Array<Byte>)

onPong

open fun onPong(pattern: T)

onPSubscribe

open fun onPSubscribe(pattern: Array<Byte>, subscribedChannels: Int)

onPUnsubscribe

open fun onPUnsubscribe(pattern: Array<Byte>, subscribedChannels: Int)

onSubscribe

open fun onSubscribe(channel: Array<Byte>, subscribedChannels: Int)

onUnsubscribe

open fun onUnsubscribe(channel: Array<Byte>, subscribedChannels: Int)

ping

fun ping()

proceed

fun proceed(client: Connection, channels: Array<T>)

proceedWithPatterns

fun proceedWithPatterns(client: Connection, patterns: Array<T>)

psubscribe

fun psubscribe(patterns: Array<T>)

punsubscribe

fun punsubscribe()

fun subscribe(channels: Array<T>)

unsubscribe

fun unsubscribe()