Package org.redisson.pubsub

Class PubSubConnectionEntry

java.lang.Object

org.redisson.pubsub.PubSubConnectionEntry

public class PubSubConnectionEntry
extends Object

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()
Queue<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, EventListener msgListener)
void	removeListener(ChannelName channelName, RedisPubSubListener<?> listener)
io.netty.channel.ChannelFuture	subscribe(Codec codec, ChannelName channelName)
String	toString()
int	tryAcquire()
io.netty.channel.ChannelFuture	unsubscribe(ChannelName channel, RedisPubSubListener<?> listener)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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 Queue<RedisPubSubListener<?>> getListeners(ChannelName channelName)

addListener

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

removeListener

public boolean removeListener(ChannelName channelName,
                              EventListener 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 String toString()

Overrides:

toString in class Object