diff --git a/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/auth/KclSTSAssumeRoleSessionCredentialsProviderTest.java b/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/auth/KclStsAssumeRoleCredentialsProviderTest.java similarity index 86% rename from amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/auth/KclSTSAssumeRoleSessionCredentialsProviderTest.java rename to amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/auth/KclStsAssumeRoleCredentialsProviderTest.java index c479f77a..9a4d5b0c 100644 --- a/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/auth/KclSTSAssumeRoleSessionCredentialsProviderTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/auth/KclStsAssumeRoleCredentialsProviderTest.java @@ -20,7 +20,7 @@ import org.junit.Test; import static org.junit.Assert.assertEquals; -public class KclSTSAssumeRoleSessionCredentialsProviderTest { +public class KclStsAssumeRoleCredentialsProviderTest { private static final String ARN = "arn"; private static final String SESSION_NAME = "sessionName"; @@ -31,22 +31,23 @@ public class KclSTSAssumeRoleSessionCredentialsProviderTest { */ @Test public void testConstructorWithoutOptionalParams() { - new KclStsAssumeRoleCredentialsProvider(new String[] {ARN, SESSION_NAME}); + new KclStsAssumeRoleCredentialsProvider(new String[] {ARN, SESSION_NAME, "endpointRegion=us-east-1"}); } @Test public void testAcceptEndpoint() { // discovered exception during e2e testing; therefore, this test is // to simply verify the constructed STS client doesn't go *boom* - final KclStsAssumeRoleCredentialsProvider provider = new KclStsAssumeRoleCredentialsProvider(ARN, SESSION_NAME); + final KclStsAssumeRoleCredentialsProvider provider = + new KclStsAssumeRoleCredentialsProvider(ARN, SESSION_NAME, "endpointRegion=us-east-1"); provider.acceptEndpoint("endpoint", "us-east-1"); } @Test public void testVarArgs() { for (final String[] varargs : Arrays.asList( - new String[] {ARN, SESSION_NAME, "externalId=eid", "foo"}, - new String[] {ARN, SESSION_NAME, "foo", "externalId=eid"})) { + new String[] {ARN, SESSION_NAME, "externalId=eid", "foo", "endpointRegion=us-east-1"}, + new String[] {ARN, SESSION_NAME, "foo", "externalId=eid", "endpointRegion=us-east-1"})) { final VarArgsSpy provider = new VarArgsSpy(varargs); assertEquals("eid", provider.externalId); } diff --git a/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/AwsCredentialsProviderPropertyValueDecoderTest.java b/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/AwsCredentialsProviderPropertyValueDecoderTest.java index 523be732..3e9380e6 100644 --- a/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/AwsCredentialsProviderPropertyValueDecoderTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/AwsCredentialsProviderPropertyValueDecoderTest.java @@ -124,7 +124,8 @@ public class AwsCredentialsProviderPropertyValueDecoderTest { KclStsAssumeRoleCredentialsProvider.class.getSimpleName(), // name-only; needs prefix StsAssumeRoleCredentialsProvider.class.getName(), // user passes full sts package path StsAssumeRoleCredentialsProvider.class.getSimpleName())) { - final AwsCredentialsProvider provider = decoder.decodeValue(className + "|arn|sessionName"); + final AwsCredentialsProvider provider = + decoder.decodeValue(className + "|arn|sessionName|endpointRegion=us-east-1"); assertNotNull(className, provider); } }