Fix race condition: KinesisMDCA.consumerInvokers

https://build.spring.io/browse/INTEXT-AWS-JOB1-154
2018-06-25 21:58:19 -04:00
parent c655a8c4e2
commit 6f39406309
1 changed files with 0 additions and 1 deletions
--- 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();
 	}

 	/**