diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java index f6af006d..4c964594 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java @@ -1163,6 +1163,7 @@ public class Worker implements Runnable { private ShardPrioritization shardPrioritization; @Setter @Accessors(fluent = true) private IKinesisProxy kinesisProxy; + @Setter @Accessors(fluent = true) private WorkerStateChangeListener workerStateChangeListener; @VisibleForTesting