diff --git a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java index 6e82d1d..395354a 100644 --- a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java +++ b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java @@ -267,7 +267,7 @@ public class KclMessageDrivenChannelAdapter extends MessageProducerSupport { } @Override - public void destroy() { + public void destroy() throws Exception { super.destroy(); this.scheduler.shutdown(); }