luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge 039f508da1 into 1ce6123a78

Browse source
This commit is contained in:
dmatriccino 2025-05-11 07:58:06 +02:00 committed by GitHub
commit e51edbd3e8
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 29 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/MultiLangDaemonConfiguration.java
View file

@ -352,10 +352,36 @@ public class MultiLangDaemonConfiguration {
}
}
private void setRegionForClient(String name, BuilderDynaBean client, Region region, boolean override) {
if(override) {
setRegionForClient(name, client, region);
} else {
String propertyValue;
try {
propertyValue = utilsBean.getProperty(client,"region");
//Check if property is already set. If not, set region for client
if(propertyValue == null || propertyValue.isEmpty()) {
setRegionForClient(name, client, region);
}
} catch (IllegalAccessException | InvocationTargetException | NoSuchMethodException e) {
log.error("Failed to get region on {}", name, e);
throw new IllegalStateException(e);
}
}
}
public void setRegionName(Region region) {
setRegionForClient("kinesisClient", kinesisClient, region);
setRegionForClient("dynamoDbClient", dynamoDbClient, region);
setRegionForClient("cloudWatchClient", cloudWatchClient, region);
setRegionForClient("kinesisClient", kinesisClient, region, false);
setRegionForClient("dynamoDbClient", dynamoDbClient, region, false);
setRegionForClient("cloudWatchClient", cloudWatchClient, region, false);
}
public void setDynamoDBRegionName(Region region) {
setRegionForClient("dynamoDbClient", dynamoDbClient, region, true);
}
public void setCloudWatchRegionName(Region region) {
setRegionForClient("cloudWatchClient", cloudWatchClient, region, true);
}
private void setEndpointForClient(String name, BuilderDynaBean client, String endpoint) {