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

Fixing the logging statements.

Browse source
This commit is contained in:
Sahil Palvia 2018-03-05 11:09:26 -08:00
parent c070bec86e
commit 4826fd6a6f
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java
View file

@ -1327,14 +1327,14 @@ public class Worker implements Runnable {
builder.withClientConfiguration(clientConfiguration);
}
if (StringUtils.isNotEmpty(endpointUrl)) {
LOG.warn("Received configuration for both region name as " + region + ", and endpoint as "
+ endpointUrl + ". Client endpoint will overwrite region name.");
LOG.warn("Received configuration for endpoint as " + endpointUrl + ", and region as "
+ region + ".");
builder.withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endpointUrl, region));
} else if (StringUtils.isNotEmpty(region)) {
LOG.debug("The region for the client has been set to " + region);
LOG.warn("Received configuration for region as " + region + ".");
builder.withRegion(region);
} else {
LOG.debug("Endpoint URL and region are not set, setting region to us-east-1");
LOG.warn("No configuration received for endpoint and region, will default region to us-east-1");
builder.withRegion(Regions.US_EAST_1);
}
return (AmazonWebServiceClient) builder.build();