Fix race condition in the KinesisMDChannelAdapter

The `KinesisMessageDrivenChannelAdapter` may exit its `active` state,
but `consumerInvokers` won't be cleared in the main consumer loop

**Cherry-pick to master**
This commit is contained in:
Artem Bilan
2019-09-12 16:58:02 -04:00
parent 3860df6e74
commit 2d8f7d1d7e

View File

@@ -1191,6 +1191,9 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
}
}
}
synchronized (KinesisMessageDrivenChannelAdapter.this.consumerInvokers) {
KinesisMessageDrivenChannelAdapter.this.consumerInvokers.remove(this);
}
}
@Override