Package org.redisson.pubsub

Class PublishSubscribeService

java.lang.Object

org.redisson.pubsub.PublishSubscribeService

public class PublishSubscribeService
extends Object

Author:

Nikita Koksharov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PublishSubscribeService.PubSubEntry
static class	PublishSubscribeService.PubSubKey

Constructor Summary

Constructors

Constructor	Description
PublishSubscribeService(ConnectionManager connectionManager, MasterSlaveServersConfig config)

Method Summary

Modifier and Type	Method	Description
CountDownLatchPubSub	getCountDownLatchPubSub()
LockPubSub	getLockPubSub()
PubSubConnectionEntry	getPubSubEntry(ChannelName channelName)
AsyncSemaphore	getSemaphore(ChannelName channelName)
SemaphorePubSub	getSemaphorePubSub()
RFuture<Collection<PubSubConnectionEntry>>	psubscribe(ChannelName channelName, Codec codec, RedisPubSubListener<?>... listeners)
void	reattachPubSub(int slot)
void	reattachPubSub(RedisPubSubConnection redisPubSubConnection)
void	remove(MasterSlaveEntry entry)
RFuture<Void>	removeListenerAsync(PubSubType type, ChannelName channelName, Integer... listenerIds)
RFuture<Void>	removeListenerAsync(PubSubType type, ChannelName channelName, EventListener listener)
RFuture<PubSubConnectionEntry>	subscribe(Codec codec, String channelName, AsyncSemaphore semaphore, RedisPubSubListener<?>... listeners)
RFuture<PubSubConnectionEntry>	subscribe(Codec codec, ChannelName channelName, RedisPubSubListener<?>... listeners)
String	toString()
RFuture<Codec>	unsubscribe(ChannelName channelName, PubSubType topicType)
RFuture<Void>	unsubscribe(PubSubType topicType, ChannelName channelName)

Methods inherited from class java.lang.Object

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

Constructor Detail

PublishSubscribeService

public PublishSubscribeService(ConnectionManager connectionManager,
                               MasterSlaveServersConfig config)

Method Detail

getLockPubSub

public LockPubSub getLockPubSub()

getCountDownLatchPubSub

public CountDownLatchPubSub getCountDownLatchPubSub()

getSemaphorePubSub

public SemaphorePubSub getSemaphorePubSub()

getPubSubEntry

public PubSubConnectionEntry getPubSubEntry(ChannelName channelName)

psubscribe

public RFuture<Collection<PubSubConnectionEntry>> psubscribe(ChannelName channelName,
                                                             Codec codec,
                                                             RedisPubSubListener<?>... listeners)

subscribe

public RFuture<PubSubConnectionEntry> subscribe(Codec codec,
                                                ChannelName channelName,
                                                RedisPubSubListener<?>... listeners)

subscribe

public RFuture<PubSubConnectionEntry> subscribe(Codec codec,
                                                String channelName,
                                                AsyncSemaphore semaphore,
                                                RedisPubSubListener<?>... listeners)

getSemaphore

public AsyncSemaphore getSemaphore(ChannelName channelName)

unsubscribe

public RFuture<Void> unsubscribe(PubSubType topicType,
                                 ChannelName channelName)

remove

public void remove(MasterSlaveEntry entry)

unsubscribe

public RFuture<Codec> unsubscribe(ChannelName channelName,
                                  PubSubType topicType)

reattachPubSub

public void reattachPubSub(int slot)

reattachPubSub

public void reattachPubSub(RedisPubSubConnection redisPubSubConnection)

removeListenerAsync

public RFuture<Void> removeListenerAsync(PubSubType type,
                                         ChannelName channelName,
                                         EventListener listener)

removeListenerAsync

public RFuture<Void> removeListenerAsync(PubSubType type,
                                         ChannelName channelName,
                                         Integer... listenerIds)

toString

public String toString()

Overrides:

toString in class Object