org.redisson.client

Class RedisPubSubConnection

java.lang.Object

org.redisson.client.RedisConnection

org.redisson.client.RedisPubSubConnection

All Implemented Interfaces:

RedisCommands

public class RedisPubSubConnection
extends RedisConnection

Author:

Nikita Koksharov

Field Summary

Fields inherited from class org.redisson.client.RedisConnection

redisClient

Fields inherited from interface org.redisson.client.protocol.RedisCommands

ASKING, AUTH, BGREWRITEAOF, BGSAVE, BITCOUNT, BITOP, BITPOS, BITS_SIZE, BLOCKING_COMMAND_NAMES, BLOCKING_COMMANDS, BLPOP, BLPOP_VALUE, BRPOP, BRPOP_VALUE, BRPOPLPUSH, BZPOPMAX_VALUE, BZPOPMIN_VALUE, CLIENT_GETNAME, CLIENT_LIST, CLIENT_REPLY, CLIENT_SETNAME, CLUSTER_ADDSLOTS, CLUSTER_COUNTKEYSINSLOT, CLUSTER_DELSLOTS, CLUSTER_FORGET, CLUSTER_GETKEYSINSLOT, CLUSTER_INFO, CLUSTER_MEET, CLUSTER_NODES, CLUSTER_NODES_SSL, CLUSTER_REPLICATE, CLUSTER_RESET, CLUSTER_SETSLOT, CLUSTER_SLOTS, CONFIG_GET, CONFIG_RESETSTAT, CONFIG_SET, DBSIZE, DEBUG, DECR, DEL, DEL_BOOL, DEL_OBJECTS, DEL_VOID, DISCARD, DUMP, EVAL_BOOLEAN, EVAL_BOOLEAN_AMOUNT, EVAL_BOOLEAN_SAFE, EVAL_DOUBLE, EVAL_FIRST_LIST, EVAL_INTEGER, EVAL_LIST, EVAL_LONG, EVAL_LONG_SAFE, EVAL_MAP, EVAL_MAP_ENTRY, EVAL_MAP_KEY_SET, EVAL_MAP_VALUE, EVAL_MAP_VALUE_LIST, EVAL_MAP_VALUE_SET, EVAL_NULL_BOOLEAN, EVAL_OBJECT, EVAL_SET, EVAL_SSCAN, EVAL_STRING, EVAL_STRING_DATA, EVAL_VOID, EVAL_ZSCAN, EXEC, EXISTS, EXISTS_LONG, FLUSHALL, FLUSHALL_ASYNC, FLUSHDB, FLUSHDB_ASYNC, GEOADD, GEODIST, GEORADIUS_RO, GEORADIUS_STORE, GEORADIUSBYMEMBER_RO, GEORADIUSBYMEMBER_STORE, GET, GET_DOUBLE, GET_INTEGER, GET_LONG, GETBIT, GETSET, HDEL, HEXISTS, HGET, HGETALL, HGETALL_ENTRY, HKEYS, HLEN, HLEN_LONG, HMSET, HSCAN, HSET, HSET_VOID, HSETNX, HSTRLEN, HVALS, INCR, INCRBY, INCRBYFLOAT, INFO_ALL, INFO_CLIENTS, INFO_CLUSTER, INFO_COMMANDSTATS, INFO_CPU, INFO_DEFAULT, INFO_KEYSPACE, INFO_MEMORY, INFO_PERSISTENCE, INFO_REPLICATION, INFO_SERVER, INFO_STATS, KEYS, KEYSLOT, LASTSAVE, LINDEX, LINSERT_INT, LLEN_INT, LPOP, LPUSH, LPUSH_BOOLEAN, LPUSH_VOID, LRANGE, LRANGE_SET, LREM_SINGLE, LSET, LTRIM, MEMORY_USAGE, MGET, MIGRATE, MOVE, MSET, MSETNX, MULTI, NOT_EXISTS, PERSIST, PEXPIRE, PEXPIREAT, PFADD, PFCOUNT, PFMERGE, PING, PING_BOOL, PSETEX, PSUBSCRIBE, PTTL, PUBLISH, PUBSUB_COMMANDS, PUBSUB_NUMSUB, PUNSUBSCRIBE, QUIT, RANDOM_KEY, READONLY, RENAME, RENAMENX, RESTORE, RPOP, RPOPLPUSH, RPUSH, RPUSH_BOOLEAN, RPUSH_VOID, SADD, SADD_BOOL, SADD_SINGLE, SAVE, SCAN, SCARD, SCARD_INT, SCRIPT_EXISTS, SCRIPT_FLUSH, SCRIPT_KILL, SCRIPT_LOAD, SDIFF, SDIFFSTORE, SDIFFSTORE_INT, SELECT, SENTINEL_FAILOVER, SENTINEL_GET_MASTER_ADDR_BY_NAME, SENTINEL_MASTERS, SENTINEL_MONITOR, SENTINEL_REMOVE, SENTINEL_SENTINELS, SENTINEL_SLAVES, SET, SETBIT, SETBIT_VOID, SETNX, SETPXNX, SHUTDOWN, SINTER, SINTERSTORE, SINTERSTORE_INT, SISMEMBER, SMEMBERS, SMOVE, SORT_LIST, SORT_SET, SORT_TO, SPOP, SPOP_SINGLE, SRANDMEMBER, SRANDMEMBER_SINGLE, SREM_SINGLE, SSCAN, STRLEN, SUBSCRIBE, SUNION, SUNIONSTORE, SUNIONSTORE_INT, TIME, TIME_LONG, TOUCH, TOUCH_LONG, TYPE, UNLINK, UNLINK_BOOL, UNSUBSCRIBE, UNWATCH, WAIT, WATCH, XACK, XADD, XADD_VOID, XCLAIM, XCLAIM_IDS, XDEL, XGROUP, XGROUP_LONG, XLEN, XPENDING, XPENDING_ENTRIES, XRANGE, XREAD, XREAD_BLOCKING, XREAD_BLOCKING_SINGLE, XREAD_SINGLE, XREADGROUP, XREADGROUP_BLOCKING, XREADGROUP_BLOCKING_SINGLE, XREADGROUP_SINGLE, XREVRANGE, XTRIM, ZADD, ZADD_BOOL, ZADD_BOOL_RAW, ZADD_INT, ZADD_NX_BOOL, ZADD_RAW, ZCARD, ZCARD_INT, ZCOUNT, ZINCRBY, ZINTERSTORE_INT, ZLEXCOUNT, ZPOPMAX, ZPOPMIN, ZRANGE, ZRANGE_ENTRY, ZRANGE_SINGLE, ZRANGE_SINGLE_SCORE, ZRANGEBYLEX, ZRANGEBYSCORE, ZRANGEBYSCORE_ENTRY, ZRANGEBYSCORE_LIST, ZRANK, ZRANK_INT, ZREM, ZREM_LONG, ZREMRANGEBYLEX, ZREMRANGEBYRANK, ZREMRANGEBYSCORE, ZREVRANGE, ZREVRANGE_ENTRY, ZREVRANGEBYLEX, ZREVRANGEBYSCORE, ZREVRANGEBYSCORE_ENTRY, ZREVRANK, ZREVRANK_INT, ZSCAN, ZSCORE, ZSCORE_CONTAINS, ZUNIONSTORE_INT

Constructor Summary

Constructors

Constructor and Description
RedisPubSubConnection(RedisClient redisClient, io.netty.channel.Channel channel, RPromise<RedisPubSubConnection> connectionPromise)

Method Summary

Modifier and Type	Method and Description
void	addListener(RedisPubSubListener<?> listener)
void	fireDisconnected()
Map<ChannelName,Codec>	getChannels()
Map<ChannelName,Codec>	getPatternChannels()
void	onMessage(PubSubMessage message)
void	onMessage(PubSubPatternMessage message)
void	onMessage(PubSubStatusMessage message)
void	psubscribe(Codec codec, ChannelName... channels)
void	punsubscribe(ChannelName... channels)
void	removeDisconnectListener(ChannelName channel)
void	removeListener(RedisPubSubListener<?> listener)
void	subscribe(Codec codec, ChannelName... channels)
void	unsubscribe(ChannelName... channels)

Methods inherited from class org.redisson.client.RedisConnection

async, async, async, async, await, clearFastReconnect, closeAsync, create, fireConnected, forceFastReconnectAsync, getChannel, getConnectionPromise, getCurrentCommand, getFrom, getLastUsageTime, getRedisClient, isActive, isClosed, isFastReconnect, isOpen, send, send, setConnectedListener, setDisconnectedListener, setLastUsageTime, sync, sync, toString, updateChannel

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisPubSubConnection

public RedisPubSubConnection(RedisClient redisClient,
                             io.netty.channel.Channel channel,
                             RPromise<RedisPubSubConnection> connectionPromise)

Method Detail

addListener

public void addListener(RedisPubSubListener<?> listener)

removeListener

public void removeListener(RedisPubSubListener<?> listener)

onMessage

public void onMessage(PubSubStatusMessage message)

onMessage

public void onMessage(PubSubMessage message)

onMessage

public void onMessage(PubSubPatternMessage message)

subscribe

public void subscribe(Codec codec,
                      ChannelName... channels)

psubscribe

public void psubscribe(Codec codec,
                       ChannelName... channels)

unsubscribe

public void unsubscribe(ChannelName... channels)

removeDisconnectListener

public void removeDisconnectListener(ChannelName channel)

fireDisconnected

public void fireDisconnected()

Overrides:

fireDisconnected in class RedisConnection

punsubscribe

public void punsubscribe(ChannelName... channels)

getChannels

public Map<ChannelName,Codec> getChannels()

getPatternChannels

public Map<ChannelName,Codec> getPatternChannels()