K - Key type.V - Value type.public interface RedisPubSubAsyncCommands<K,V> extends RedisAsyncCommands<K,V>, RedisPubSubConnection<K,V>
| Modifier and Type | Method and Description |
|---|---|
void |
addListener(RedisPubSubListener<K,V> listener)
Add a new listener.
|
StatefulRedisPubSubConnection<K,V> |
getStatefulConnection() |
RedisFuture<Void> |
psubscribe(K... patterns)
Listen for messages published to channels matching the given patterns.
|
RedisFuture<Void> |
punsubscribe(K... patterns)
Stop listening for messages posted to channels matching the given patterns.
|
void |
removeListener(RedisPubSubListener<K,V> listener)
Remove an existing listener.
|
RedisFuture<Void> |
subscribe(K... channels)
Listen for messages published to the given channels.
|
RedisFuture<Void> |
unsubscribe(K... channels)
Stop listening for messages posted to the given channels.
|
auth, select, setTimeoutasking, clusterAddSlots, clusterCountFailureReports, clusterCountKeysInSlot, clusterDelSlots, clusterFailover, clusterFlushslots, clusterForget, clusterGetKeysInSlot, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterSlaves, clusterSlots, del, mget, mset, msetnx, readOnly, readWritehdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hsetnx, hstrlen, hvals, hvalsdump, exists, expire, expireat, expireat, keys, keys, migrate, move, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pttl, randomkey, rename, renamenx, restore, scan, scan, scan, scan, scan, scan, scan, scan, sort, sort, sort, sort, sortStore, ttl, type, unlinkappend, bitcount, bitcount, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, decr, decrby, get, getbit, getrange, getset, incr, incrby, incrbyfloat, mget, psetex, set, set, setbit, setex, setnx, setrange, strlenblpop, brpop, brpoplpush, lindex, linsert, llen, lpop, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpoplpush, rpush, rpushxsadd, scard, sdiff, sdiff, sdiffstore, sinter, sinter, sinterstore, sismember, smembers, smembers, smove, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sunion, sunion, sunionstorezadd, zadd, zadd, zadd, zaddincr, zcard, zcount, zcount, zincrby, zinterstore, zinterstore, zlexcount, zrange, zrange, zrangebylex, zrangebylex, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangeWithScores, zrangeWithScores, zrank, zrem, zremrangebylex, zremrangebyrank, zremrangebyscore, zremrangebyscore, zrevrange, zrevrange, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscore, zunionstore, zunionstoredigest, eval, eval, evalsha, evalsha, scriptExists, scriptFlush, scriptKill, scriptLoadbgrewriteaof, bgsave, clientGetname, clientKill, clientKill, clientList, clientPause, clientSetname, command, commandCount, commandInfo, commandInfo, configGet, configResetstat, configRewrite, configSet, dbsize, debugCrashAndRecover, debugHtstats, debugObject, debugOom, debugReload, debugRestart, debugSdslen, debugSegfault, flushall, flushallAsync, flushdb, flushdbAsync, info, info, lastsave, save, shutdown, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, sync, timepfadd, pfcount, pfmergegeoadd, geoadd, geodist, geopos, georadius, georadius, georadiusbymember, georadiusbymembervoid addListener(RedisPubSubListener<K,V> listener)
addListener in interface RedisPubSubConnection<K,V>listener - Listener.void removeListener(RedisPubSubListener<K,V> listener)
removeListener in interface RedisPubSubConnection<K,V>listener - Listener.RedisFuture<Void> psubscribe(K... patterns)
psubscribe in interface RedisPubSubConnection<K,V>patterns - the patternspsubscribe completionRedisFuture<Void> punsubscribe(K... patterns)
punsubscribe in interface RedisPubSubConnection<K,V>patterns - the patternspunsubscribe completionRedisFuture<Void> subscribe(K... channels)
subscribe in interface RedisPubSubConnection<K,V>channels - the channelssubscribe completionRedisFuture<Void> unsubscribe(K... channels)
unsubscribe in interface RedisPubSubConnection<K,V>channels - the channelsunsubscribe completion.StatefulRedisPubSubConnection<K,V> getStatefulConnection()
getStatefulConnection in interface RedisAsyncCommands<K,V>getStatefulConnection in interface RedisAsyncConnection<K,V>Copyright © 2016. All rights reserved.