|
byte[]
|
addToSet(String key, Boolean mustSucceed, byte[] message)
Add the message payload to the set stored at the specified key.
|
|
byte[]
|
addToSortedSet(String key, Double score, Boolean mustSucceed, byte[] message)
Add the message payload with the desired score to the sorted set stored at the specified key.
|
|
List<Serializable>
|
allKeys()
|
|
List<Serializable>
|
allKeys(String partitionName)
|
|
List<String>
|
allPartitions()
|
|
void
|
close()
|
|
void
|
close(String partitionName)
|
|
boolean
|
contains(Serializable key, String partitionName)
|
|
boolean
|
contains(Serializable key)
|
|
void
|
destroyJedis()
|
|
void
|
disposePartition(String partitionName)
|
|
byte[]
|
get(String key)
Get the value of the specified key.
|
|
int
|
getConnectionTimeout()
|
|
byte[]
|
getFromHash(String key, String field)
Get the value stored at the specified field in the hash at the specified key.
|
|
String
|
getHost()
|
|
JedisPool
|
getJedisPool()
|
|
String
|
getPassword()
|
|
GenericObjectPool.Config
|
getPoolConfig()
|
|
int
|
getPort()
|
|
Set<byte[]>
|
getRangeByIndex(String key, Integer start, Integer end, RedisModule.SortedSetOrder order)
Retrieve a range of values from the sorted set stored at the specified key.
|
|
Set<byte[]>
|
getRangeByScore(String key, Double min, Double max, RedisModule.SortedSetOrder order)
Retrieve a range of values from the sorted set stored at the specified key.
|
|
int
|
getReconnectionFrequency()
|
|
void
|
initializeJedis()
|
|
boolean
|
isPersistent()
|
|
void
|
open(String partitionName)
|
|
void
|
open()
|
|
byte[]
|
popFromList(String key, RedisModule.ListPushSide side)
Pop a value from the desired side of the list stored at the specified key.
|
|
byte[]
|
popFromSet(String key)
Pops a random value from the set stored at the specified key.
|
|
byte[]
|
publish(String channel, Boolean mustSucceed, byte[] message)
Publish the message payload to the specified channel.
|
|
byte[]
|
pushToList(String key, RedisModule.ListPushSide side, Boolean ifExists, byte[] message)
Push the message payload to the desired side (LEFT or RIGHT) of the list stored at the specified key.
|
|
byte[]
|
randomMemberFromSet(String key)
Reads a random value from the set stored at the specified key.
|
|
Serializable
|
remove(Serializable key, String partitionName)
|
|
Serializable
|
remove(Serializable key)
|
|
Serializable
|
retrieve(Serializable key)
|
|
Serializable
|
retrieve(Serializable key, String partitionName)
|
|
byte[]
|
set(String key, Integer expire, Boolean ifNotExists, byte[] message)
Set key to hold the payload.
|
|
void
|
setConnectionTimeout(int connectionTimeout)
|
|
void
|
setHost(String host)
|
|
byte[]
|
setInHash(String key, String field, Boolean ifNotExists, byte[] message)
Set the specified hash field to the message payload.
|
|
void
|
setPassword(String password)
|
|
void
|
setPoolConfig(GenericObjectPool.Config poolConfig)
|
|
void
|
setPort(int port)
|
|
void
|
setReconnectionFrequency(int reconnectionFrequency)
|
|
void
|
store(Serializable key, Serializable value)
|
|
void
|
store(Serializable key, Serializable value, String partitionName)
|
|
void
|
subscribe(List<String> channels, SourceCallback callback)
Subscribe to the specified channels.
|
From class
org.mule.module.redis.RedisModule