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)

Method Summary

Modifier and Type	Method	Description
void	checkPatternSupport(RedisConnection connection)
void	checkShardingSupport(ShardedSubscriptionMode mode, RedisConnection connection)
int	countListeners(List<ChannelName> channelNames)
CountDownLatchPubSub	getCountDownLatchPubSub()
LockPubSub	getLockPubSub()
String	getPublishCommand()
SemaphorePubSub	getSemaphorePubSub()
boolean	hasEntry(ChannelName channelName)
boolean	isMultiEntity(ChannelName channelName)
boolean	isPatternSupported()
boolean	isShardingSupported()
CompletableFuture<Collection<PubSubConnectionEntry>>	psubscribe(ChannelName channelName, Codec codec, RedisPubSubListener<?>... listeners)
void	reattachPubSub(int slot)
void	reattachPubSub(RedisPubSubConnection redisPubSubConnection)
void	remove(MasterSlaveEntry entry)
CompletableFuture<Void>	removeAllListenersAsync(PubSubType type, ChannelName... channelNames)
CompletableFuture<Void>	removeFlushListenerAsync(int listenerId)
CompletableFuture<Void>	removeListenerAsync(PubSubType type, List<ChannelName> channelNames, Integer... listenerIds)
CompletableFuture<Void>	removeListenerAsync(PubSubType type, List<ChannelName> channelNames, EventListener listener)
void	setPatternSupported(boolean patternSupported)
void	setShardingSupported(boolean shardingSupported)
CompletableFuture<PubSubConnectionEntry>	ssubscribe(Codec codec, List<ChannelName> channelNames, RedisPubSubListener<?>... listeners)
CompletableFuture<Integer>	subscribe(String key, Codec codec, CommandAsyncExecutor commandExecutor, TrackingListener listener)
CompletableFuture<List<PubSubConnectionEntry>>	subscribe(Codec codec, List<ChannelName> channelNames, RedisPubSubListener<?>... listeners)
CompletableFuture<List<PubSubConnectionEntry>>	subscribe(Codec codec, ChannelName channelName, RedisPubSubListener<?>... listeners)
CompletableFuture<Integer>	subscribe(CommandAsyncExecutor commandExecutor, FlushListener listener)
CompletableFuture<Integer>	subscribe(CommandAsyncExecutor commandExecutor, TrackingListener listener)
String	toString()
CompletableFuture<Codec>	unsubscribe(ChannelName channelName, PubSubType topicType)

Methods inherited from class java.lang.Object

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

Constructor Details

PublishSubscribeService

public PublishSubscribeService(ConnectionManager connectionManager)

Method Details

getLockPubSub

public LockPubSub getLockPubSub()

getCountDownLatchPubSub

public CountDownLatchPubSub getCountDownLatchPubSub()

getSemaphorePubSub

public SemaphorePubSub getSemaphorePubSub()

countListeners

public int countListeners(List<ChannelName> channelNames)

hasEntry

public boolean hasEntry(ChannelName channelName)

psubscribe

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

isMultiEntity

public boolean isMultiEntity(ChannelName channelName)

subscribe

public CompletableFuture<Integer> subscribe(CommandAsyncExecutor commandExecutor,
 FlushListener listener)

subscribe

public CompletableFuture<Integer> subscribe(CommandAsyncExecutor commandExecutor,
 TrackingListener listener)

removeFlushListenerAsync

public CompletableFuture<Void> removeFlushListenerAsync(int listenerId)

subscribe

public CompletableFuture<Integer> subscribe(String key,
 Codec codec,
 CommandAsyncExecutor commandExecutor,
 TrackingListener listener)

subscribe

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

subscribe

public CompletableFuture<List<PubSubConnectionEntry>> subscribe(Codec codec,
 List<ChannelName> channelNames,
 RedisPubSubListener<?>... listeners)

ssubscribe

public CompletableFuture<PubSubConnectionEntry> ssubscribe(Codec codec,
 List<ChannelName> channelNames,
 RedisPubSubListener<?>... listeners)

remove

public void remove(MasterSlaveEntry entry)

unsubscribe

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

reattachPubSub

public void reattachPubSub(int slot)

reattachPubSub

public void reattachPubSub(RedisPubSubConnection redisPubSubConnection)

removeListenerAsync

public CompletableFuture<Void> removeListenerAsync(PubSubType type,
 List<ChannelName> channelNames,
 EventListener listener)

removeListenerAsync

public CompletableFuture<Void> removeListenerAsync(PubSubType type,
 List<ChannelName> channelNames,
 Integer... listenerIds)

removeAllListenersAsync

public CompletableFuture<Void> removeAllListenersAsync(PubSubType type,
 ChannelName... channelNames)

checkPatternSupport

public void checkPatternSupport(RedisConnection connection)

checkShardingSupport

public void checkShardingSupport(ShardedSubscriptionMode mode,
 RedisConnection connection)

isPatternSupported

public boolean isPatternSupported()

setPatternSupported

public void setPatternSupported(boolean patternSupported)

setShardingSupported

public void setShardingSupported(boolean shardingSupported)

isShardingSupported

public boolean isShardingSupported()

getPublishCommand

public String getPublishCommand()

toString

public String toString()

Overrides:

toString in class Object