NSS Gateway/xyz.noisif.nss.gateway.kv.ws/RedisTopicWsSubscriber

RedisTopicWsSubscriber

@Singleton

open class RedisTopicWsSubscriber : AbstractKvSubscriber<Array<Byte>>

Constructors

RedisTopicWsSubscriber

@Inject

constructor(localSessionDispatcher: LocalSessionDispatcher)

Properties

localSessionDispatcher

private val localSessionDispatcher: LocalSessionDispatcher

private open var subscribed: Boolean

Functions

open fun getChannel(): KvChannel

getChannelParams

open fun getChannelParams(): Array<Any>

open fun getMode(): SubscriptionMode

open fun getPayloadType(): Class<Array<Byte>>

open fun handle(channel: String, params: Array<String>, message: Array<Byte>)

open fun isSubscribed(): Boolean

open fun setSubscribed(subscribed: Boolean)