Skip to content

Commit f466614

Browse files
committed
update README and Changelog
1 parent 79489c2 commit f466614

File tree

3 files changed

+15
-1
lines changed

3 files changed

+15
-1
lines changed

CHANGELOG.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,5 +2,11 @@
22
The format is based on [Keep a Changelog](http://keepachangelog.com/)
33
and this project adheres to [Semantic Versioning](http://semver.org/).
44

5+
## 1.1.0 (07/24/2020)
6+
- Add Jedis implementation. Spout defaults to using the Lettuce redis library, but you can configure
7+
to use the Jedis library instead via the `RedisStreamSpoutConfig.withJedisClientLibrary()` method.
8+
- Bugfix on Spout deploy, consumer thread started during `open()` lifecycle call instead of `activate()`.
9+
- Bugfix on Spout restart, resume consuming first from consumers personal pending list.
10+
511
## 1.0.0 (07/20/2020)
612
- Initial release!

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
<groupId>org.sourcelab.storm.spout</groupId>
88
<artifactId>redis-stream-spout</artifactId>
9-
<version>1.0.0</version>
9+
<version>1.1.0</version>
1010

1111
<!-- Module Description and Ownership -->
1212
<name>Redis Streams Spout for Apache Storm.</name>

src/main/java/org/sourcelab/storm/spout/redis/RedisStreamSpoutConfig.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -415,10 +415,18 @@ public Builder withMetricsEnabled(final boolean enabled) {
415415
return this;
416416
}
417417

418+
/**
419+
* Configure the spout to use the Lettuce client library for communicating with redis.
420+
* @return Builder instance.
421+
*/
418422
public Builder withLettuceClientLibrary() {
419423
return withClientType(ClientType.LETTUCE);
420424
}
421425

426+
/**
427+
* Configure the spout to use the Jedis client library for communicating with redis.
428+
* @return Builder instance.
429+
*/
422430
public Builder withJedisClientLibrary() {
423431
return withClientType(ClientType.JEDIS);
424432
}

0 commit comments

Comments
 (0)