From 6f39406309712c381a69efa09e83ffe8eb67d93a Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Mon, 25 Jun 2018 21:58:19 -0400
Subject: [PATCH] Fix race condition: KinesisMDCA.consumerInvokers

https://build.spring.io/browse/INTEXT-AWS-JOB1-154
---
 .../aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java  | 1 -
 1 file changed, 1 deletion(-)

diff --git a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
index 49596b4..607e2c3 100644
--- a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
+++ b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
@@ -673,7 +673,6 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
 			shardConsumer.stop();
 		}
 		this.shardConsumers.clear();
-		this.consumerInvokers.clear();
 	}
 
 	/**