| 程序包 | 说明 |
|---|---|
| redis.clients.jedis | |
| redis.clients.jedis.commands | |
| redis.clients.jedis.params |
| 限定符和类型 | 字段和说明 |
|---|---|
static StreamEntryID |
StreamEntryID.LAST_ENTRY
Should be used only with XGROUP CREATE
XGROUP CREATE mystream consumer-group-name $
|
static StreamEntryID |
StreamEntryID.NEW_ENTRY
Should be used only with XADD
XADD mystream * field1 value1
|
static StreamEntryID |
StreamEntryID.UNRECEIVED_ENTRY
Should be used only with XREADGROUP
XREADGROUP $GroupName $ConsumerName BLOCK 2000 COUNT 10 STREAMS mystream >
|
| 限定符和类型 | 字段和说明 |
|---|---|
static Builder<StreamEntryID> |
BuilderFactory.STREAM_ENTRY_ID |
static Builder<java.util.List<StreamEntryID>> |
BuilderFactory.STREAM_ENTRY_ID_LIST |
| 限定符和类型 | 方法和说明 |
|---|---|
StreamEntryID |
StreamPendingEntry.getID() |
StreamEntryID |
StreamEntry.getID() |
StreamEntryID |
StreamGroupInfo.getLastDeliveredId() |
StreamEntryID |
StreamInfo.getLastGeneratedId() |
StreamEntryID |
StreamPendingSummary.getMaxId() |
StreamEntryID |
StreamPendingSummary.getMinId() |
StreamEntryID |
ShardedJedis.xadd(java.lang.String key,
java.util.Map<java.lang.String,java.lang.String> hash,
XAddParams params) |
StreamEntryID |
JedisCluster.xadd(java.lang.String key,
java.util.Map<java.lang.String,java.lang.String> hash,
XAddParams params) |
StreamEntryID |
Jedis.xadd(java.lang.String key,
java.util.Map<java.lang.String,java.lang.String> hash,
XAddParams params) |
StreamEntryID |
ShardedJedis.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
StreamEntryID |
JedisCluster.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
StreamEntryID |
Jedis.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
StreamEntryID |
ShardedJedis.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
StreamEntryID |
JedisCluster.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
StreamEntryID |
Jedis.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
| 限定符和类型 | 方法和说明 |
|---|---|
Response<StreamEntryID> |
PipelineBase.xadd(java.lang.String key,
java.util.Map<java.lang.String,java.lang.String> hash,
XAddParams params) |
Response<StreamEntryID> |
PipelineBase.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
Response<StreamEntryID> |
PipelineBase.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
int |
StreamEntryID.compareTo(StreamEntryID other) |
long |
ShardedJedis.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids) |
Response<java.lang.Long> |
PipelineBase.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids) |
java.lang.Long |
JedisCluster.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids) |
long |
Jedis.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids)
XACK key group ID [ID ...]
|
void |
Client.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids) |
StreamEntryID |
ShardedJedis.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
Response<StreamEntryID> |
PipelineBase.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
StreamEntryID |
JedisCluster.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
StreamEntryID |
Jedis.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
StreamEntryID |
ShardedJedis.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
Response<StreamEntryID> |
PipelineBase.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
StreamEntryID |
JedisCluster.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
StreamEntryID |
Jedis.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
void |
Client.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
java.util.List<StreamEntry> |
ShardedJedis.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... ids) |
Response<java.util.List<StreamEntry>> |
PipelineBase.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... ids) |
java.util.List<StreamEntry> |
JedisCluster.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... ids) |
java.util.List<StreamEntry> |
Jedis.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... ids) |
void |
Client.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... 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) |
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) |
long |
ShardedJedis.xdel(java.lang.String key,
StreamEntryID... ids) |
Response<java.lang.Long> |
PipelineBase.xdel(java.lang.String key,
StreamEntryID... ids) |
java.lang.Long |
JedisCluster.xdel(java.lang.String key,
StreamEntryID... ids) |
long |
Jedis.xdel(java.lang.String key,
StreamEntryID... ids) |
void |
Client.xdel(java.lang.String key,
StreamEntryID... ids) |
java.lang.String |
ShardedJedis.xgroupCreate(java.lang.String key,
java.lang.String consumer,
StreamEntryID id,
boolean makeStream) |
Response<java.lang.String> |
PipelineBase.xgroupCreate(java.lang.String key,
java.lang.String groupname,
StreamEntryID id,
boolean makeStream) |
java.lang.String |
JedisCluster.xgroupCreate(java.lang.String key,
java.lang.String groupname,
StreamEntryID id,
boolean makeStream) |
java.lang.String |
Jedis.xgroupCreate(java.lang.String key,
java.lang.String groupname,
StreamEntryID id,
boolean makeStream) |
void |
Client.xgroupCreate(java.lang.String key,
java.lang.String groupname,
StreamEntryID id,
boolean makeStream) |
java.lang.String |
ShardedJedis.xgroupSetID(java.lang.String key,
java.lang.String groupname,
StreamEntryID id) |
Response<java.lang.String> |
PipelineBase.xgroupSetID(java.lang.String key,
java.lang.String groupname,
StreamEntryID id) |
java.lang.String |
JedisCluster.xgroupSetID(java.lang.String key,
java.lang.String groupname,
StreamEntryID id) |
java.lang.String |
Jedis.xgroupSetID(java.lang.String key,
java.lang.String groupname,
StreamEntryID id) |
void |
Client.xgroupSetID(java.lang.String key,
java.lang.String groupname,
StreamEntryID id) |
java.util.List<StreamPendingEntry> |
ShardedJedis.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername) |
Response<java.util.List<StreamPendingEntry>> |
PipelineBase.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername) |
java.util.List<StreamPendingEntry> |
JedisCluster.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername) |
java.util.List<StreamPendingEntry> |
Jedis.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername) |
void |
Client.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername) |
java.util.List<StreamEntry> |
ShardedJedis.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end) |
Response<java.util.List<StreamEntry>> |
PipelineBase.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end) |
java.util.List<StreamEntry> |
JedisCluster.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end) |
java.util.List<StreamEntry> |
Jedis.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end) |
void |
Client.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end) |
java.util.List<StreamEntry> |
ShardedJedis.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count) |
Response<java.util.List<StreamEntry>> |
PipelineBase.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count) |
java.util.List<StreamEntry> |
JedisCluster.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count) |
java.util.List<StreamEntry> |
Jedis.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count)
XRANGE key start end COUNT count
|
void |
Client.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count) |
void |
Client.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
long count) |
java.util.List<StreamEntry> |
ShardedJedis.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start) |
Response<java.util.List<StreamEntry>> |
PipelineBase.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start) |
java.util.List<StreamEntry> |
JedisCluster.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start) |
java.util.List<StreamEntry> |
Jedis.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start) |
void |
Client.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start) |
java.util.List<StreamEntry> |
ShardedJedis.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count) |
Response<java.util.List<StreamEntry>> |
PipelineBase.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count) |
java.util.List<StreamEntry> |
JedisCluster.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count) |
java.util.List<StreamEntry> |
Jedis.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count)
XREVRANGE key end start COUNT count
|
void |
Client.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count) |
| 限定符和类型 | 方法和说明 |
|---|---|
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> |
MultiKeyPipelineBase.xread(XReadParams xReadParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>> |
JedisCluster.xread(XReadParams xReadParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>> |
Jedis.xread(XReadParams xReadParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
void |
Client.xread(XReadParams params,
java.util.Map<java.lang.String,StreamEntryID> streams) |
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> |
MultiKeyPipelineBase.xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams xReadGroupParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>> |
JedisCluster.xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams xReadGroupParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>> |
Jedis.xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams xReadGroupParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
void |
Client.xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams params,
java.util.Map<java.lang.String,StreamEntryID> streams) |
| 构造器和说明 |
|---|
StreamEntry(StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> fields) |
StreamPendingEntry(StreamEntryID id,
java.lang.String consumerName,
long idleTime,
long deliveredTimes) |
StreamPendingSummary(long total,
StreamEntryID minId,
StreamEntryID maxId,
java.util.Map<java.lang.String,java.lang.Long> consumerMessageCount) |
| 限定符和类型 | 方法和说明 |
|---|---|
StreamEntryID |
JedisCommands.xadd(java.lang.String key,
java.util.Map<java.lang.String,java.lang.String> hash,
XAddParams params)
XADD key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT count]] *|ID field value [field value ...]
|
StreamEntryID |
JedisClusterCommands.xadd(java.lang.String key,
java.util.Map<java.lang.String,java.lang.String> hash,
XAddParams params)
XADD key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT count]] *|ID field value [field value ...]
|
StreamEntryID |
JedisCommands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash)
XADD key ID field string [field string ...]
|
StreamEntryID |
JedisClusterCommands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash)
XADD key ID field string [field string ...]
|
StreamEntryID |
JedisCommands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength)
XADD key MAXLEN ~ LEN ID field string [field string ...]
|
StreamEntryID |
JedisClusterCommands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength)
XADD key MAXLEN ~ LEN ID field string [field string ...]
|
| 限定符和类型 | 方法和说明 |
|---|---|
Response<StreamEntryID> |
RedisPipeline.xadd(java.lang.String key,
java.util.Map<java.lang.String,java.lang.String> hash,
XAddParams params) |
Response<StreamEntryID> |
RedisPipeline.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
Response<StreamEntryID> |
RedisPipeline.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
Response<java.lang.Long> |
RedisPipeline.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids) |
long |
JedisCommands.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids)
XACK key group ID [ID ...]
|
java.lang.Long |
JedisClusterCommands.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids)
XACK key group ID [ID ...]
|
void |
Commands.xack(java.lang.String key,
java.lang.String group,
StreamEntryID... ids) |
Response<StreamEntryID> |
RedisPipeline.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash) |
StreamEntryID |
JedisCommands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash)
XADD key ID field string [field string ...]
|
StreamEntryID |
JedisClusterCommands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash)
XADD key ID field string [field string ...]
|
Response<StreamEntryID> |
RedisPipeline.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
StreamEntryID |
JedisCommands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength)
XADD key MAXLEN ~ LEN ID field string [field string ...]
|
StreamEntryID |
JedisClusterCommands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength)
XADD key MAXLEN ~ LEN ID field string [field string ...]
|
void |
Commands.xadd(java.lang.String key,
StreamEntryID id,
java.util.Map<java.lang.String,java.lang.String> hash,
long maxLen,
boolean approximateLength) |
Response<java.util.List<StreamEntry>> |
RedisPipeline.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... ids) |
java.util.List<StreamEntry> |
JedisCommands.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... ids)
XCLAIM
|
java.util.List<StreamEntry> |
JedisClusterCommands.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... ids)
XCLAIM
|
void |
Commands.xclaim(java.lang.String key,
java.lang.String group,
java.lang.String consumername,
long minIdleTime,
long newIdleTime,
int retries,
boolean force,
StreamEntryID... 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<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) |
Response<java.lang.Long> |
RedisPipeline.xdel(java.lang.String key,
StreamEntryID... ids) |
long |
JedisCommands.xdel(java.lang.String key,
StreamEntryID... ids)
XDEL key ID [ID ...]
|
java.lang.Long |
JedisClusterCommands.xdel(java.lang.String key,
StreamEntryID... ids)
XDEL key ID [ID ...]
|
void |
Commands.xdel(java.lang.String key,
StreamEntryID... ids) |
Response<java.lang.String> |
RedisPipeline.xgroupCreate(java.lang.String key,
java.lang.String groupname,
StreamEntryID id,
boolean makeStream) |
java.lang.String |
JedisCommands.xgroupCreate(java.lang.String key,
java.lang.String groupname,
StreamEntryID id,
boolean makeStream)
XGROUP CREATE
|
java.lang.String |
JedisClusterCommands.xgroupCreate(java.lang.String key,
java.lang.String groupname,
StreamEntryID id,
boolean makeStream)
XGROUP CREATE
|
void |
Commands.xgroupCreate(java.lang.String key,
java.lang.String consumer,
StreamEntryID id,
boolean makeStream) |
Response<java.lang.String> |
RedisPipeline.xgroupSetID(java.lang.String key,
java.lang.String groupname,
StreamEntryID id) |
java.lang.String |
JedisCommands.xgroupSetID(java.lang.String key,
java.lang.String groupname,
StreamEntryID id)
XGROUP SETID
|
java.lang.String |
JedisClusterCommands.xgroupSetID(java.lang.String key,
java.lang.String groupname,
StreamEntryID id)
XGROUP SETID
|
void |
Commands.xgroupSetID(java.lang.String key,
java.lang.String consumer,
StreamEntryID id) |
Response<java.util.List<StreamPendingEntry>> |
RedisPipeline.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername) |
java.util.List<StreamPendingEntry> |
JedisCommands.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername)
XPENDING key group [start end count] [consumer]
|
java.util.List<StreamPendingEntry> |
JedisClusterCommands.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername)
XPENDING key group [start end count] [consumer]
|
void |
Commands.xpending(java.lang.String key,
java.lang.String groupname,
StreamEntryID start,
StreamEntryID end,
int count,
java.lang.String consumername) |
Response<java.util.List<StreamEntry>> |
RedisPipeline.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end) |
java.util.List<StreamEntry> |
JedisCommands.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end)
XRANGE key start end
|
java.util.List<StreamEntry> |
JedisClusterCommands.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end)
XRANGE key start end
|
void |
Commands.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end) |
Response<java.util.List<StreamEntry>> |
RedisPipeline.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count) |
java.util.List<StreamEntry> |
JedisCommands.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count)
XRANGE key start end COUNT count
|
java.util.List<StreamEntry> |
JedisClusterCommands.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count)
XRANGE key start end COUNT count
|
void |
Commands.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
int count) |
void |
Commands.xrange(java.lang.String key,
StreamEntryID start,
StreamEntryID end,
long count)
|
Response<java.util.List<StreamEntry>> |
RedisPipeline.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start) |
java.util.List<StreamEntry> |
JedisCommands.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start)
XREVRANGE key end start
|
java.util.List<StreamEntry> |
JedisClusterCommands.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start)
XREVRANGE key end start
|
void |
Commands.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start) |
Response<java.util.List<StreamEntry>> |
RedisPipeline.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count) |
java.util.List<StreamEntry> |
JedisCommands.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count)
XREVRANGE key end start COUNT count
|
java.util.List<StreamEntry> |
JedisClusterCommands.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count)
XREVRANGE key end start COUNT count
|
void |
Commands.xrevrange(java.lang.String key,
StreamEntryID end,
StreamEntryID start,
int count) |
| 限定符和类型 | 方法和说明 |
|---|---|
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>> |
MultiKeyJedisClusterCommands.xread(XReadParams xReadParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> |
MultiKeyCommandsPipeline.xread(XReadParams xReadParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>> |
MultiKeyCommands.xread(XReadParams xReadParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
void |
Commands.xread(XReadParams params,
java.util.Map<java.lang.String,StreamEntryID> streams) |
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>> |
MultiKeyJedisClusterCommands.xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams xReadGroupParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> |
MultiKeyCommandsPipeline.xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams xReadGroupParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>> |
MultiKeyCommands.xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams xReadGroupParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
void |
Commands.xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams params,
java.util.Map<java.lang.String,StreamEntryID> streams) |
| 限定符和类型 | 方法和说明 |
|---|---|
XPendingParams |
XPendingParams.end(StreamEntryID end) |
XPendingParams |
XPendingParams.start(StreamEntryID start) |