类的使用
redis.clients.jedis.StreamEntry

使用StreamEntry的程序包

程序包	说明
redis.clients.jedis
redis.clients.jedis.commands

redis.clients.jedis中StreamEntry的使用

类型参数类型为StreamEntry的redis.clients.jedis中的字段

限定符和类型	字段和说明
static Builder<StreamEntry>	BuilderFactory.STREAM_ENTRY
static Builder<java.util.List<StreamEntry>>	BuilderFactory.STREAM_ENTRY_LIST
static Builder<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>>	BuilderFactory.STREAM_READ_RESPONSE

返回StreamEntry的redis.clients.jedis中的方法

限定符和类型	方法和说明
StreamEntry	StreamInfo.getFirstEntry()
StreamEntry	StreamInfo.getLastEntry()

返回变量类型为StreamEntry的类型的redis.clients.jedis中的方法

限定符和类型	方法和说明
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)
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)
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)
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
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>>	MultiKeyPipelineBase.xread(int count, long block, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams)
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>	JedisCluster.xread(int count, long block, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams)
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>	Jedis.xread(int count, long block, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...]
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)
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, int count, long block, boolean noAck, java.util.Map.Entry<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, int count, long block, boolean noAck, java.util.Map.Entry<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, int count, long block, boolean noAck, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...]
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)
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)
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

redis.clients.jedis.commands中StreamEntry的使用

返回变量类型为StreamEntry的类型的redis.clients.jedis.commands中的方法

限定符和类型	方法和说明
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 [IDLE ] [TIME ] [RETRYCOUNT ] [FORCE] [JUSTID]
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 [IDLE ] [TIME ] [RETRYCOUNT ] [FORCE] [JUSTID]
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)
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
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
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>	MultiKeyJedisClusterCommands.xread(int count, long block, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) 已过时。 This method will be removed due to bug regarding block param. Use MultiKeyJedisClusterCommands.xread(redis.clients.jedis.params.XReadParams, java.util.Map).
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>>	MultiKeyCommandsPipeline.xread(int count, long block, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) 已过时。 Use MultiKeyCommandsPipeline.xread(redis.clients.jedis.params.XReadParams, java.util.Map).
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>	MultiKeyCommands.xread(int count, long block, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) 已过时。 This method will be removed due to bug regarding block param. Use MultiKeyCommands.xread(redis.clients.jedis.params.XReadParams, java.util.Map).
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>	JedisClusterCommands.xread(int count, long block, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) 已过时。 This will be removed in future version. Use MultiKeyJedisClusterCommands.xread(int, long, java.util.Map.Entry...).
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)
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>	MultiKeyJedisClusterCommands.xreadGroup(java.lang.String groupname, java.lang.String consumer, int count, long block, boolean noAck, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) 已过时。 This method will be removed due to bug regarding block param. Use MultiKeyJedisClusterCommands.xreadGroup(java.lang.String, java.lang.String, redis.clients.jedis.params.XReadGroupParams, java.util.Map).
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, int count, long block, boolean noAck, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) 已过时。 Use MultiKeyCommandsPipeline.xreadGroup(java.lang.String, java.lang.String, redis.clients.jedis.params.XReadGroupParams, java.util.Map).
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>	MultiKeyCommands.xreadGroup(java.lang.String groupname, java.lang.String consumer, int count, long block, boolean noAck, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) 已过时。 This method will be removed due to bug regarding block param. Use MultiKeyCommands.xreadGroup(java.lang.String, java.lang.String, redis.clients.jedis.params.XReadGroupParams, java.util.Map).
java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>	JedisClusterCommands.xreadGroup(java.lang.String groupname, java.lang.String consumer, int count, long block, boolean noAck, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) 已过时。 This will be removed in future version. Use MultiKeyJedisClusterCommands.xreadGroup(java.lang.String, java.lang.String, int, long, boolean, java.util.Map.Entry...).
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)
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
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