JedisPubSubRegistrar

Constructors

constructor(redisClient: UnifiedJedis)

private val LOG: Logger

private val redisClient: UnifiedJedis

private open fun buildChannelName(subscriber: KvSubscriber<out Any>): String

private open fun registerAsync(logType: String, threadPrefix: String, channelOrPattern: String, redisAction: RunnableWithException)

private open fun registerBinary(logType: String, threadPrefix: String, subscriber: KvSubscriber<Array<Byte>>, jedisAction: BiConsumer<BinaryJedisPubSub, Array<Array<Byte>>>)

private open fun registerString(logType: String, threadPrefix: String, subscriber: KvSubscriber<String>, jedisAction: BiConsumer<JedisPubSub, Array<String>>)