spring-projects/spring-integration-aws

Invalid default value in KclMessageDrivenChannelAdapter -> cause IllegalArgumentException

Refal opened this issue · 1 comments

Refal commented

During creating KclMessageDrivenChannelAdapter
if config == null will be created default class: KinesisClientLibConfiguration
with parameter leaseCleanupIntervalMillis == 0

This parameter is used in com.amazonaws.services.kinesis.leases.impl.LeaseCleanupManager.start():
deletionThreadPool.scheduleAtFixedRate(new LeaseCleanupThread(), INITIAL_DELAY, leaseCleanupIntervalMillis, TimeUnit.MILLISECONDS);

that is causing IllegalArgumentExcpetoin

If you see the fix, feel free to open a Pull Request and we will review and merge shortly.

Thank you!