Cancel KinesisMDChA.shCMFuture after active=false
It's misleading to see an error for interrupted `KinesisMessageDrivenChannelAdapter.ShardConsumerManager` on shutdown. * Move `this.shardConsumerManagerFuture.cancel(true)` in the `doStop()` after `this.active = false;`
This commit is contained in:
@@ -776,8 +776,8 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport
|
||||
super.doStop();
|
||||
stopConsumers();
|
||||
|
||||
this.shardConsumerManagerFuture.cancel(true);
|
||||
this.active = false;
|
||||
this.shardConsumerManagerFuture.cancel(true);
|
||||
}
|
||||
|
||||
private void stopConsumers() {
|
||||
|
||||
Reference in New Issue
Block a user