From 0d9d2ff0526f3af7c9ffa22de64bb2e79e4b9d29 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 10 Sep 2019 13:46:00 -0400 Subject: [PATCH] Destroy() must throws Exception --- .../aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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(); }