Release 2.0.4 (October 18, 2018)
- Added method to retrieve leases from the LeaseCoordinator and LeaseTaker.
- Fixed a race condition shutting down the Scheduler before it has completed initialization.
- Added
HierarchicalShardSyncer
which replaces the staticShardSyncer
.
HierarchicalShardSyncer
removes the contention between multiple instances of the Scheduler when running under a single JVM. - Added
TaskExecutionListener
which allows monitoring of tasks being executed by theShardConsumer
.
The listener is invoked before and after a task is executed by theShardConsumer
.