K
- Key type.V
- Value type.public class RedisPubSubReactiveCommandsImpl<K,V> extends RedisReactiveCommandsImpl<K,V> implements RedisPubSubReactiveCommands<K,V>
codec, commandBuilder, connection, multi
Constructor and Description |
---|
RedisPubSubReactiveCommandsImpl(StatefulRedisPubSubConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new connection.
|
Modifier and Type | Method and Description |
---|---|
void |
addListener(RedisPubSubListener<K,V> listener)
Add a new listener.
|
StatefulRedisPubSubConnection<K,V> |
getStatefulConnection() |
Observable<ChannelMessage<K,V>> |
observeChannels()
Observable for messages (message) received though channel subscriptions.
|
Observable<PatternMessage<K,V>> |
observePatterns()
Observable for messages (pmessage) received though pattern subscriptions.
|
Observable<Success> |
psubscribe(K... patterns)
Listen for messages published to channels matching the given patterns.
|
Observable<Success> |
punsubscribe(K... patterns)
Stop listening for messages posted to channels matching the given patterns.
|
void |
removeListener(RedisPubSubListener<K,V> listener)
Remove an existing listener.
|
Observable<Success> |
subscribe(K... channels)
Listen for messages published to the given channels.
|
Observable<Success> |
unsubscribe(K... channels)
Stop listening for messages posted to the given channels.
|
append, asking, auth, bgrewriteaof, bgsave, bitcount, bitcount, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, blpop, brpop, brpoplpush, clientGetname, clientKill, clientKill, clientList, clientPause, clientSetname, close, clusterAddSlots, clusterCountFailureReports, clusterCountKeysInSlot, clusterDelSlots, clusterFailover, clusterFlushslots, clusterForget, clusterGetKeysInSlot, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterSlaves, clusterSlots, command, commandCount, commandInfo, commandInfo, configGet, configResetstat, configRewrite, configSet, createDissolvingObservable, createDissolvingObservable, createObservable, createObservable, dbsize, debugCrashAndRecover, debugHtstats, debugObject, debugOom, debugReload, debugRestart, debugSdslen, debugSegfault, decr, decrby, del, del, digest, discard, dump, echo, eval, eval, evalsha, evalsha, exec, exists, exists, expire, expireat, expireat, flushall, flushallAsync, flushdb, flushdbAsync, geoadd, geoadd, geodist, geopos, georadius, georadius, georadiusbymember, georadiusbymember, get, getbit, getConnection, getrange, getset, getSuccessObservable, hdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hsetnx, hstrlen, hvals, hvals, incr, incrby, incrbyfloat, info, info, isOpen, keys, keys, lastsave, lindex, linsert, llen, lpop, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, mget, mget, mget, mget, migrate, move, mset, msetnx, multi, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pfadd, pfadd, pfcount, pfcount, pfmerge, pfmerge, ping, psetex, pttl, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, randomkey, readOnly, readWrite, rename, renamenx, reset, restore, role, rpop, rpoplpush, rpush, rpushx, sadd, save, scan, scan, scan, scan, scan, scan, scan, scan, scard, scriptExists, scriptFlush, scriptKill, scriptLoad, sdiff, sdiff, sdiffstore, select, set, set, setbit, setex, setnx, setrange, setTimeout, shutdown, sinter, sinter, sinterstore, sismember, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, smembers, smembers, smove, sort, sort, sort, sort, sortStore, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, strlen, sunion, sunion, sunionstore, sync, time, ttl, type, unlink, unlink, unwatch, waitForReplication, watch, zadd, 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, zunionstore
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
auth, select, setTimeout
asking, 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, readWrite
hdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hsetnx, hstrlen, hvals, hvals
dump, 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, unlink
append, 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, strlen
blpop, brpop, brpoplpush, lindex, linsert, llen, lpop, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpoplpush, rpush, rpushx
sadd, 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, sunionstore
zadd, 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, zunionstore
digest, eval, eval, evalsha, evalsha, scriptExists, scriptFlush, scriptKill, scriptLoad
bgrewriteaof, 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, time
pfadd, pfcount, pfmerge
geoadd, geoadd, geodist, geopos, georadius, georadius, georadiusbymember, georadiusbymember
close, echo, isOpen, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, reset, role, waitForReplication
public RedisPubSubReactiveCommandsImpl(StatefulRedisPubSubConnection<K,V> connection, RedisCodec<K,V> codec)
connection
- the connection .codec
- Codec used to encode/decode keys and values.public void addListener(RedisPubSubListener<K,V> listener)
addListener
in interface RedisPubSubReactiveCommands<K,V>
listener
- Listener.public Observable<PatternMessage<K,V>> observePatterns()
RedisPubSubReactiveCommands
RedisPubSubReactiveCommands.psubscribe(Object[])
.observePatterns
in interface RedisPubSubReactiveCommands<K,V>
public Observable<ChannelMessage<K,V>> observeChannels()
RedisPubSubReactiveCommands
RedisPubSubReactiveCommands.subscribe(Object[])
.observeChannels
in interface RedisPubSubReactiveCommands<K,V>
public void removeListener(RedisPubSubListener<K,V> listener)
removeListener
in interface RedisPubSubReactiveCommands<K,V>
listener
- Listener.public Observable<Success> psubscribe(K... patterns)
RedisPubSubReactiveCommands
psubscribe
in interface RedisPubSubReactiveCommands<K,V>
patterns
- the patternspsubscribe
commandpublic Observable<Success> punsubscribe(K... patterns)
RedisPubSubReactiveCommands
punsubscribe
in interface RedisPubSubReactiveCommands<K,V>
patterns
- the patternspunsubscribe
commandpublic Observable<Success> subscribe(K... channels)
RedisPubSubReactiveCommands
subscribe
in interface RedisPubSubReactiveCommands<K,V>
channels
- the channelssubscribe
commandpublic Observable<Success> unsubscribe(K... channels)
RedisPubSubReactiveCommands
unsubscribe
in interface RedisPubSubReactiveCommands<K,V>
channels
- the channelsunsubscribe
command.public StatefulRedisPubSubConnection<K,V> getStatefulConnection()
getStatefulConnection
in interface RedisReactiveCommands<K,V>
getStatefulConnection
in interface RedisPubSubReactiveCommands<K,V>
getStatefulConnection
in class RedisReactiveCommandsImpl<K,V>
Copyright © 2016. All rights reserved.