feature(worker): make Worker#getLeaseCoordinator public

This commit is contained in:
bencvdb 2019-06-26 09:35:59 -07:00
parent 08bf7f7000
commit 9e102af3dd

View file

@ -468,7 +468,7 @@ public class Worker implements Runnable {
/** /**
* @return the leaseCoordinator * @return the leaseCoordinator
*/ */
KinesisClientLibLeaseCoordinator getLeaseCoordinator() { public KinesisClientLibLeaseCoordinator getLeaseCoordinator() {
return leaseCoordinator; return leaseCoordinator;
} }
@ -1030,6 +1030,10 @@ public class Worker implements Runnable {
return new WorkerThreadPoolExecutor(threadFactory); return new WorkerThreadPoolExecutor(threadFactory);
} }
public ExecutorService returnExecutorService() {
return this.executorService;
}
private static <S, T> void setField(final S source, final String field, final Consumer<T> t, T value) { private static <S, T> void setField(final S source, final String field, final Consumer<T> t, T value) {
try { try {
t.accept(value); t.accept(value);