|
byte[]
|
addToSet(String key, boolean mustSucceed, String value, MuleEvent muleEvent)
Add the message payload to the set stored at the specified key.
|
|
byte[]
|
addToSortedSet(String key, double score, boolean mustSucceed, String value, MuleEvent muleEvent)
Add the message payload with the desired score to the sorted set stored at the specified key.
|
|
List<Serializable>
|
allKeys(String partitionName)
|
|
List<Serializable>
|
allKeys()
|
|
List<String>
|
allPartitions()
|
|
void
|
close()
|
|
void
|
close(String partitionName)
|
|
boolean
|
contains(Serializable key, String partitionName)
|
|
boolean
|
contains(Serializable key)
|
|
Long
|
decrement(String key, long step)
Decrements the number stored at key by step.
|
|
void
|
destroyJedis()
|
|
void
|
disposePartition(String partitionName)
|
|
Boolean
|
exists(String key)
Test if the specified key exists.
|
|
Boolean
|
expire(String key, int seconds)
Set a timeout on the specified key.
|
|
Boolean
|
expireAt(String key, long unixTime)
Set a timeout in the form of a UNIX timestamp (Number of seconds elapsed since 1 Jan 1970) on
the specified key.
|
|
byte[]
|
get(String key)
Get the value of the specified key.
|
|
int
|
getConnectionTimeout()
|
|
String
|
getDefaultPartitionName()
|
|
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, int start, int 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()
|
|
Long
|
getTtl(String key)
Get the remaining time to live in seconds of a volatile key.
|
|
Long
|
increment(String key, long step)
Increments the number stored at key by step.
|
|
Long
|
incrementHash(String key, String field, long step)
Increments the number stored at field in the hash stored at key by increment.
|
|
Double
|
incrementSortedSet(String key, double step, String value, MuleEvent muleEvent)
Increments the score of member in the sorted set stored at key by increment.
|
|
void
|
initializeJedis()
|
|
boolean
|
isPersistent()
|
|
void
|
open(String partitionName)
|
|
void
|
open()
|
|
Boolean
|
persist(String key)
Undo an expire or expireAt ; turning the volatile key into a normal key.
|
|
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, String message, MuleEvent muleEvent)
Publish the message payload to the specified channel.
|
|
byte[]
|
pushToList(String key, RedisModule.ListPushSide side, boolean ifExists, String value, MuleEvent muleEvent)
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)
|
|
Serializable
|
remove(Serializable key, String partitionName)
|
|
Serializable
|
retrieve(Serializable key)
|
|
Serializable
|
retrieve(Serializable key, String partitionName)
|
|
byte[]
|
set(String key, Integer expire, boolean ifNotExists, String value, MuleEvent muleEvent)
Set key to hold the payload.
|
|
void
|
setConnectionTimeout(int connectionTimeout)
|
|
void
|
setDefaultPartitionName(String defaultPartitionName)
|
|
void
|
setHost(String host)
|
|
byte[]
|
setInHash(String key, String field, boolean ifNotExists, String value, MuleEvent muleEvent)
Set the specified hash field to the message payload.
|
|
void
|
setMuleContext(MuleContext muleContext)
|
|
void
|
setPassword(String password)
|
|
void
|
setPoolConfig(GenericObjectPool.Config poolConfig)
|
|
void
|
setPort(int port)
|
|
void
|
setReconnectionFrequency(int reconnectionFrequency)
|
|
void
|
store(Serializable key, Serializable value, String partitionName)
|
|
void
|
store(Serializable key, Serializable value)
|
|
void
|
subscribe(List<String> channels, SourceCallback callback)
Subscribe to the specified channels.
|
From class
org.mule.module.redis.adapters.RedisModuleMetadataAdapater