Skip to content

Commit

Permalink
Polishing.
Browse files Browse the repository at this point in the history
Add support for Jedis Streams using JedisCluster. Add fromMany(…) for non-pipelined usage to JedisInvoker.

Reformat code, add author tags. Extract Jedis-specific stream type converters to StreamConverters. Properly convert StreamEntry and StreamEntryID into list/map. Update tests.

See #1711
Original pull request: #1977.
  • Loading branch information
mp911de committed Mar 16, 2021
1 parent a31c739 commit 9b39c09
Show file tree
Hide file tree
Showing 18 changed files with 938 additions and 402 deletions.
1 change: 1 addition & 0 deletions src/main/asciidoc/new-features.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ This section briefly covers items that are new and noteworthy in the latest rele
* ACL authentication support for Redis Standalone, Redis Cluster and Master/Replica.
* Password support for Redis Sentinel using Jedis.
* Support for `ZREVRANGEBYLEX` and `ZLEXCOUNT` commands.
* Support for Stream Commands using Jedis.

[[new-in-2.3.0]]
== New in Spring Data Redis 2.3
Expand Down
2 changes: 0 additions & 2 deletions src/main/asciidoc/reference/redis-streams.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@ While Pub/Sub relies on the broadcasting of transient messages (i.e. if you don'

The `org.springframework.data.redis.connection` and `org.springframework.data.redis.stream` packages provide the core functionality for Redis Streams.

NOTE: Redis Stream support is currently only available through the <<redis:connectors:lettuce, Lettuce client>> as it is not yet supported by <<redis:connectors:jedis, Jedis>>.

[[redis.streams.send]]
== Appending

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -303,6 +303,15 @@ public RedisSetCommands setCommands() {
return new JedisClusterSetCommands(this);
}

/*
* (non-Javadoc)
* @see org.springframework.data.redis.connection.RedisConnection#streamCommands()
*/
@Override
public RedisStreamCommands streamCommands() {
return new JedisClusterStreamCommands(this);
}

/*
* (non-Javadoc)
* @see org.springframework.data.redis.connection.RedisConnection#zSetCommands()
Expand Down
Loading

0 comments on commit 9b39c09

Please sign in to comment.