Package org.redisson.spring.data.connection

Class RedissonStreamCommands

  • All Implemented Interfaces:
    org.springframework.data.redis.connection.RedisStreamCommands
    public class RedissonStreamCommands
extends Object
implements org.springframework.data.redis.connection.RedisStreamCommands
    Author:
    Nikita Koksharov

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      Long xAck​(byte[] key, String group, org.springframework.data.redis.connection.stream.RecordId... recordIds)  
      org.springframework.data.redis.connection.stream.RecordId xAdd​(org.springframework.data.redis.connection.stream.MapRecord<byte[],​byte[],​byte[]> record)  
      Long xDel​(byte[] key, org.springframework.data.redis.connection.stream.RecordId... recordIds)  
      String xGroupCreate​(byte[] key, String groupName, org.springframework.data.redis.connection.stream.ReadOffset readOffset)  
      Boolean xGroupDelConsumer​(byte[] key, org.springframework.data.redis.connection.stream.Consumer consumer)  
      Boolean xGroupDestroy​(byte[] key, String groupName)  
      Long xLen​(byte[] key)  
      List<org.springframework.data.redis.connection.stream.ByteRecord> xRange​(byte[] key, org.springframework.data.domain.Range<String> range, org.springframework.data.redis.connection.RedisZSetCommands.Limit limit)  
      List<org.springframework.data.redis.connection.stream.ByteRecord> xRead​(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, org.springframework.data.redis.connection.stream.StreamOffset<byte[]>... streams)  
      List<org.springframework.data.redis.connection.stream.ByteRecord> xReadGroup​(org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, org.springframework.data.redis.connection.stream.StreamOffset<byte[]>... streams)  
      List<org.springframework.data.redis.connection.stream.ByteRecord> xRevRange​(byte[] key, org.springframework.data.domain.Range<String> range, org.springframework.data.redis.connection.RedisZSetCommands.Limit limit)  
      Long xTrim​(byte[] key, long count)  

      • Methods inherited from interface org.springframework.data.redis.connection.RedisStreamCommands

        xAck, xAdd, xDel, xGroupDelConsumer, xRange, xRead, xReadGroup, xRevRange

    • Constructor Detail

      • RedissonStreamCommands

        public RedissonStreamCommands​(RedissonConnection connection)

    • Method Detail

      • xAck

        public Long xAck​(byte[] key,
                 String group,
                 org.springframework.data.redis.connection.stream.RecordId... recordIds)
        Specified by:
        xAck in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xAdd

        public org.springframework.data.redis.connection.stream.RecordId xAdd​(org.springframework.data.redis.connection.stream.MapRecord<byte[],​byte[],​byte[]> record)
        Specified by:
        xAdd in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xDel

        public Long xDel​(byte[] key,
                 org.springframework.data.redis.connection.stream.RecordId... recordIds)
        Specified by:
        xDel in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xGroupCreate

        public String xGroupCreate​(byte[] key,
                           String groupName,
                           org.springframework.data.redis.connection.stream.ReadOffset readOffset)
        Specified by:
        xGroupCreate in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xGroupDelConsumer

        public Boolean xGroupDelConsumer​(byte[] key,
                                 org.springframework.data.redis.connection.stream.Consumer consumer)
        Specified by:
        xGroupDelConsumer in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xGroupDestroy

        public Boolean xGroupDestroy​(byte[] key,
                             String groupName)
        Specified by:
        xGroupDestroy in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xLen

        public Long xLen​(byte[] key)
        Specified by:
        xLen in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xRange

        public List<org.springframework.data.redis.connection.stream.ByteRecord> xRange​(byte[] key,
                                                                                org.springframework.data.domain.Range<String> range,
                                                                                org.springframework.data.redis.connection.RedisZSetCommands.Limit limit)
        Specified by:
        xRange in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xRead

        public List<org.springframework.data.redis.connection.stream.ByteRecord> xRead​(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                                                               org.springframework.data.redis.connection.stream.StreamOffset<byte[]>... streams)
        Specified by:
        xRead in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xReadGroup

        public List<org.springframework.data.redis.connection.stream.ByteRecord> xReadGroup​(org.springframework.data.redis.connection.stream.Consumer consumer,
                                                                                    org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                                                                    org.springframework.data.redis.connection.stream.StreamOffset<byte[]>... streams)
        Specified by:
        xReadGroup in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xRevRange

        public List<org.springframework.data.redis.connection.stream.ByteRecord> xRevRange​(byte[] key,
                                                                                   org.springframework.data.domain.Range<String> range,
                                                                                   org.springframework.data.redis.connection.RedisZSetCommands.Limit limit)
        Specified by:
        xRevRange in interface org.springframework.data.redis.connection.RedisStreamCommands

      • xTrim

        public Long xTrim​(byte[] key,
                  long count)
        Specified by:
        xTrim in interface org.springframework.data.redis.connection.RedisStreamCommands