程序包 | 说明 |
---|---|
redis.clients.jedis | |
redis.clients.jedis.commands | |
redis.clients.jedis.params |
限定符和类型 | 方法和说明 |
---|---|
Response<java.util.List<byte[]>> |
MultiKeyPipelineBase.xreadGroup(byte[] groupname,
byte[] consumer,
XReadGroupParams xReadGroupParams,
java.util.Map.Entry<byte[],byte[]>... streams) |
java.util.List<byte[]> |
BinaryJedisCluster.xreadGroup(byte[] groupname,
byte[] consumer,
XReadGroupParams xReadGroupParams,
java.util.Map.Entry<byte[],byte[]>... streams) |
java.util.List<byte[]> |
BinaryJedis.xreadGroup(byte[] groupname,
byte[] consumer,
XReadGroupParams xReadGroupParams,
java.util.Map.Entry<byte[],byte[]>... streams) |
void |
BinaryClient.xreadGroup(byte[] groupname,
byte[] consumer,
XReadGroupParams params,
java.util.Map.Entry<byte[],byte[]>... 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) |
限定符和类型 | 方法和说明 |
---|---|
Response<java.util.List<byte[]>> |
MultiKeyBinaryRedisPipeline.xreadGroup(byte[] groupname,
byte[] consumer,
XReadGroupParams xReadGroupParams,
java.util.Map.Entry<byte[],byte[]>... streams) |
java.util.List<byte[]> |
MultiKeyBinaryJedisClusterCommands.xreadGroup(byte[] groupname,
byte[] consumer,
XReadGroupParams xReadGroupParams,
java.util.Map.Entry<byte[],byte[]>... streams) |
java.util.List<byte[]> |
MultiKeyBinaryCommands.xreadGroup(byte[] groupname,
byte[] consumer,
XReadGroupParams xReadGroupParams,
java.util.Map.Entry<byte[],byte[]>... 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) |
限定符和类型 | 方法和说明 |
---|---|
XReadGroupParams |
XReadGroupParams.block(int block) |
XReadGroupParams |
XReadGroupParams.count(int count) |
XReadGroupParams |
XReadGroupParams.noAck() |
static XReadGroupParams |
XReadGroupParams.xReadGroupParams() |