Downgrade to SI-6.0.x for SC compatibility

* Check for streams configured for `KclMessageDrivenChannelAdapter`
This commit is contained in:
abilan
2023-03-24 17:12:40 -04:00
parent bd1371fa61
commit ae2403e196
2 changed files with 2 additions and 1 deletions

View File

@@ -38,7 +38,7 @@ ext {
servletApiVersion = '6.0.0'
log4jVersion = '2.19.0'
springCloudAwsVersion = '3.0.0-RC1'
springIntegrationVersion = '6.1.0-SNAPSHOT'
springIntegrationVersion = '6.0.4'
kinesisClientVersion = '2.4.5'
kinesisProducerVersion = '0.15.5'
testcontainersVersion = '1.17.6'

View File

@@ -144,6 +144,7 @@ public class KclMessageDrivenChannelAdapter extends MessageProducerSupport {
Assert.notNull(kinesisClient, "'kinesisClient' must not be null.");
Assert.notNull(cloudWatchClient, "'cloudWatchClient' must not be null.");
Assert.notNull(dynamoDBClient, "'dynamoDBClient' must not be null.");
Assert.notEmpty(streams, "'streams' must not be empty.");
this.streams = streams;
this.kinesisClient = kinesisClient;
this.cloudWatchClient = cloudWatchClient;