程序包 | 说明 |
---|---|
redis.clients.jedis | |
redis.clients.jedis.commands | |
redis.clients.jedis.params |
限定符和类型 | 方法和说明 |
---|---|
Response<java.util.List<byte[]>> |
PipelineBase.xclaim(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryShardedJedis.xclaim(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryJedisCluster.xclaim(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryJedis.xclaim(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
void |
BinaryClient.xclaim(byte[] key,
byte[] groupname,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<StreamEntry> |
ShardedJedis.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
Response<java.util.List<StreamEntry>> |
PipelineBase.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
java.util.List<StreamEntry> |
JedisCluster.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
java.util.List<StreamEntry> |
Jedis.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
void |
Client.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
Response<java.util.List<byte[]>> |
PipelineBase.xclaimJustId(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryShardedJedis.xclaimJustId(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryJedisCluster.xclaimJustId(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryJedis.xclaimJustId(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
void |
BinaryClient.xclaimJustId(byte[] key,
byte[] groupname,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<StreamEntryID> |
ShardedJedis.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
Response<java.util.List<StreamEntryID>> |
PipelineBase.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
java.util.List<StreamEntryID> |
JedisCluster.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
java.util.List<StreamEntryID> |
Jedis.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
void |
Client.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
限定符和类型 | 方法和说明 |
---|---|
Response<java.util.List<byte[]>> |
BinaryRedisPipeline.xclaim(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryJedisCommands.xclaim(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryJedisClusterCommands.xclaim(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
Response<java.util.List<StreamEntry>> |
RedisPipeline.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
java.util.List<StreamEntry> |
JedisCommands.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids)
XCLAIM
|
java.util.List<StreamEntry> |
JedisClusterCommands.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
void |
Commands.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
Response<java.util.List<byte[]>> |
BinaryRedisPipeline.xclaimJustId(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryJedisCommands.xclaimJustId(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
java.util.List<byte[]> |
BinaryJedisClusterCommands.xclaimJustId(byte[] key,
byte[] group,
byte[] consumername,
long minIdleTime,
XClaimParams params,
byte[]... ids) |
Response<java.util.List<StreamEntryID>> |
RedisPipeline.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
java.util.List<StreamEntryID> |
JedisCommands.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids)
XCLAIM
|
java.util.List<StreamEntryID> |
JedisClusterCommands.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
void |
Commands.xclaimJustId(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
XClaimParams params,
StreamEntryID... ids) |
限定符和类型 | 方法和说明 |
---|---|
XClaimParams |
XClaimParams.force()
Creates the pending message entry in the PEL even if certain specified IDs are not already in
the PEL assigned to a different client.
|
XClaimParams |
XClaimParams.idle(long idleTime)
Set the idle time (last time it was delivered) of the message.
|
XClaimParams |
XClaimParams.retryCount(int count)
Set the retry counter to the specified value.
|
XClaimParams |
XClaimParams.time(long idleUnixTime)
Set the idle time to a specific Unix time (in milliseconds).
|
static XClaimParams |
XClaimParams.xClaimParams() |