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

Add casting check for create() provider

Browse source
This commit is contained in:
Ethan Katnic 2024-08-22 10:33:07 -07:00
parent 8aa81dc255
commit f8eafb457a
1 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/AwsCredentialsProviderPropertyValueDecoder.java
View file

@ -187,9 +187,16 @@ class AwsCredentialsProviderPropertyValueDecoder implements IPropertyValueDecode
return constructor.construct(); return constructor.construct();
} catch (InstantiationException e) { } catch (InstantiationException e) {
try { try {
// Try to create an instance using .create()
Method createMethod = clazz.getDeclaredMethod("create"); Method createMethod = clazz.getDeclaredMethod("create");
if (Modifier.isStatic(createMethod.getModifiers())) { if (Modifier.isStatic(createMethod.getModifiers())) {
return (T) createMethod.invoke(null); Object provider = createMethod.invoke(null);
if (provider instanceof AwsCredentialsProvider) {
return (T) provider;
} else {
log.warn("Returned provider is not an instance of {}", AwsCredentialsProvider.class.getName());
return null;
}
} else { } else {
log.warn("Found non-static create() method in {}", providerName); log.warn("Found non-static create() method in {}", providerName);
} }