Package org.redisson.pubsub

Class PubSubConnectionEntry

org.redisson.pubsub.PubSubConnectionEntry

public class PubSubConnectionEntry
extends 

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
PubSubConnectionEntry(RedisPubSubConnection conn, int subscriptionsPerConnection)

Method Summary

Modifier and Type	Method	Description
void	addListener(ChannelName channelName, RedisPubSubListener<?> listener)
int	countListeners(ChannelName channelName)
RedisPubSubConnection	getConnection()
<RedisPubSubListener<?>>	getListeners(ChannelName channelName)
SubscribeListener	getSubscribeFuture(ChannelName channel, PubSubType type)
boolean	hasListeners(ChannelName channelName)
io.netty.channel.ChannelFuture	psubscribe(Codec codec, ChannelName pattern)
io.netty.channel.ChannelFuture	punsubscribe(ChannelName channel, RedisPubSubListener<?> listener)
int	release()
boolean	removeListener(ChannelName channelName, int listenerId)
boolean	removeListener(ChannelName channelName, msgListener)
void	removeListener(ChannelName channelName, RedisPubSubListener<?> listener)
io.netty.channel.ChannelFuture	subscribe(Codec codec, ChannelName channelName)
	toString()
int	tryAcquire()
io.netty.channel.ChannelFuture	unsubscribe(ChannelName channel, RedisPubSubListener<?> listener)

Methods inherited from class java.lang.

, , , , , , , , ,

Constructor Detail

PubSubConnectionEntry

public PubSubConnectionEntry(RedisPubSubConnection conn,
                             int subscriptionsPerConnection)

Method Detail

countListeners

public int countListeners(ChannelName channelName)

hasListeners

public boolean hasListeners(ChannelName channelName)

getListeners

public <RedisPubSubListener<?>> getListeners(ChannelName channelName)

addListener

public void addListener(ChannelName channelName,
                        RedisPubSubListener<?> listener)

removeListener

public boolean removeListener(ChannelName channelName,
                               msgListener)

removeListener

public boolean removeListener(ChannelName channelName,
                              int listenerId)

removeListener

public void removeListener(ChannelName channelName,
                           RedisPubSubListener<?> listener)

tryAcquire

public int tryAcquire()

release

public int release()

subscribe

public io.netty.channel.ChannelFuture subscribe(Codec codec,
                                                ChannelName channelName)

psubscribe

public io.netty.channel.ChannelFuture psubscribe(Codec codec,
                                                 ChannelName pattern)

getSubscribeFuture

public SubscribeListener getSubscribeFuture(ChannelName channel,
                                            PubSubType type)

unsubscribe

public io.netty.channel.ChannelFuture unsubscribe(ChannelName channel,
                                                  RedisPubSubListener<?> listener)

punsubscribe

public io.netty.channel.ChannelFuture punsubscribe(ChannelName channel,
                                                   RedisPubSubListener<?> listener)

getConnection

public RedisPubSubConnection getConnection()

toString

public  toString()

Overrides:

in class