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

JedisPubSubAdapter

open class JedisPubSubAdapter : JedisPubSub

Constructors

JedisPubSubAdapter

constructor(kvSubscriber: KvSubscriber<String>, paramExtractor: ChannelParamExtractor)

Properties

private val authenticator: JedisSafeAuthenticator

private val kvSubscriber: KvSubscriber<String>

private val LOG: Logger

private val paramExtractor: ChannelParamExtractor

pingResultHandler

private val pingResultHandler: Consumer<Any>

subscribedChannels

open val subscribedChannels: Int

Functions

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

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

fun isSubscribed(): Boolean

open fun onMessage(channel: String, message: String)

open fun onPMessage(pattern: String, channel: String, message: String)

open fun onPong(pattern: T)

open fun onPSubscribe(pattern: String, subscribedChannels: Int)

open fun onPUnsubscribe(pattern: String, subscribedChannels: Int)

open fun onSubscribe(channel: String, subscribedChannels: Int)

open fun onUnsubscribe(channel: String, subscribedChannels: Int)

fun ping()

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

proceedWithPatterns

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

fun psubscribe(patterns: Array<T>)

fun punsubscribe()

fun subscribe(channels: Array<T>)

fun unsubscribe()