This commit is contained in:
Nathan Smith 2016-06-07 22:11:07 +00:00
commit 00b9fb421b
4 changed files with 15 additions and 15 deletions

View file

@ -23,7 +23,7 @@
</licenses> </licenses>
<properties> <properties>
<aws-java-sdk.version>1.10.61</aws-java-sdk.version> <aws-java-sdk.version>1.11.5</aws-java-sdk.version>
</properties> </properties>
<dependencies> <dependencies>

View file

@ -21,6 +21,8 @@ import java.util.List;
import java.util.Set; import java.util.Set;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
import com.amazonaws.regions.Region;
import com.amazonaws.regions.Regions;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
@ -82,7 +84,7 @@ public class KinesisProxy implements IKinesisProxyExtended {
* @param streamName Data records will be fetched from this stream * @param streamName Data records will be fetched from this stream
* @param credentialProvider Provides credentials for signing Kinesis requests * @param credentialProvider Provides credentials for signing Kinesis requests
* @param endpoint Kinesis endpoint * @param endpoint Kinesis endpoint
* @param serviceName service name * @param serviceName This parameter is ignored
* @param regionId region id * @param regionId region id
* @param describeStreamBackoffTimeInMillis Backoff time for DescribeStream calls in milliseconds * @param describeStreamBackoffTimeInMillis Backoff time for DescribeStream calls in milliseconds
* @param maxDescribeStreamRetryAttempts Number of retry attempts for DescribeStream calls * @param maxDescribeStreamRetryAttempts Number of retry attempts for DescribeStream calls
@ -96,7 +98,6 @@ public class KinesisProxy implements IKinesisProxyExtended {
int maxDescribeStreamRetryAttempts) { int maxDescribeStreamRetryAttempts) {
this(streamName, credentialProvider, buildClientSettingEndpoint(credentialProvider, this(streamName, credentialProvider, buildClientSettingEndpoint(credentialProvider,
endpoint, endpoint,
serviceName,
regionId), describeStreamBackoffTimeInMillis, maxDescribeStreamRetryAttempts); regionId), describeStreamBackoffTimeInMillis, maxDescribeStreamRetryAttempts);
@ -105,10 +106,10 @@ public class KinesisProxy implements IKinesisProxyExtended {
private static AmazonKinesisClient buildClientSettingEndpoint(AWSCredentialsProvider credentialProvider, private static AmazonKinesisClient buildClientSettingEndpoint(AWSCredentialsProvider credentialProvider,
String endpoint, String endpoint,
String serviceName,
String regionId) { String regionId) {
AmazonKinesisClient client = new AmazonKinesisClient(credentialProvider); AmazonKinesisClient client = new AmazonKinesisClient(credentialProvider);
client.setEndpoint(endpoint, serviceName, regionId); client.setRegion(Region.getRegion(Regions.fromName(regionId)));
client.setEndpoint(endpoint);
return client; return client;
} }

View file

@ -16,6 +16,8 @@ package com.amazonaws.services.kinesis.clientlibrary.proxies;
import com.amazonaws.ClientConfiguration; import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.AWSCredentialsProvider; import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.regions.Region;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.kinesis.AmazonKinesis; import com.amazonaws.services.kinesis.AmazonKinesis;
import com.amazonaws.services.kinesis.AmazonKinesisClient; import com.amazonaws.services.kinesis.AmazonKinesisClient;
@ -40,7 +42,7 @@ public class KinesisProxyFactory implements IKinesisProxyFactory {
* @param endpoint Amazon Kinesis endpoint to use * @param endpoint Amazon Kinesis endpoint to use
*/ */
public KinesisProxyFactory(AWSCredentialsProvider credentialProvider, String endpoint) { public KinesisProxyFactory(AWSCredentialsProvider credentialProvider, String endpoint) {
this(credentialProvider, new ClientConfiguration(), endpoint, defaultServiceName, defaultRegionId, this(credentialProvider, new ClientConfiguration(), endpoint, defaultRegionId,
DEFAULT_DESCRIBE_STREAM_BACKOFF_MILLIS, DEFAULT_DESCRIBE_STREAM_RETRY_TIMES); DEFAULT_DESCRIBE_STREAM_BACKOFF_MILLIS, DEFAULT_DESCRIBE_STREAM_RETRY_TIMES);
} }
@ -54,7 +56,7 @@ public class KinesisProxyFactory implements IKinesisProxyFactory {
public KinesisProxyFactory(AWSCredentialsProvider credentialProvider, public KinesisProxyFactory(AWSCredentialsProvider credentialProvider,
ClientConfiguration clientConfig, ClientConfiguration clientConfig,
String endpoint) { String endpoint) {
this(credentialProvider, clientConfig, endpoint, defaultServiceName, defaultRegionId, this(credentialProvider, clientConfig, endpoint, defaultRegionId,
DEFAULT_DESCRIBE_STREAM_BACKOFF_MILLIS, DEFAULT_DESCRIBE_STREAM_RETRY_TIMES); DEFAULT_DESCRIBE_STREAM_BACKOFF_MILLIS, DEFAULT_DESCRIBE_STREAM_RETRY_TIMES);
} }
@ -74,7 +76,6 @@ public class KinesisProxyFactory implements IKinesisProxyFactory {
* @param credentialProvider credentials provider used to sign requests * @param credentialProvider credentials provider used to sign requests
* @param clientConfig Client Configuration used when instantiating an AmazonKinesisClient * @param clientConfig Client Configuration used when instantiating an AmazonKinesisClient
* @param endpoint Amazon Kinesis endpoint to use * @param endpoint Amazon Kinesis endpoint to use
* @param serviceName service name
* @param regionId region id * @param regionId region id
* @param describeStreamBackoffTimeInMillis backoff time for describing stream in millis * @param describeStreamBackoffTimeInMillis backoff time for describing stream in millis
* @param maxDescribeStreamRetryAttempts Number of retry attempts for DescribeStream calls * @param maxDescribeStreamRetryAttempts Number of retry attempts for DescribeStream calls
@ -82,14 +83,12 @@ public class KinesisProxyFactory implements IKinesisProxyFactory {
KinesisProxyFactory(AWSCredentialsProvider credentialProvider, KinesisProxyFactory(AWSCredentialsProvider credentialProvider,
ClientConfiguration clientConfig, ClientConfiguration clientConfig,
String endpoint, String endpoint,
String serviceName,
String regionId, String regionId,
long describeStreamBackoffTimeInMillis, long describeStreamBackoffTimeInMillis,
int maxDescribeStreamRetryAttempts) { int maxDescribeStreamRetryAttempts) {
this(credentialProvider, buildClientSettingEndpoint(credentialProvider, this(credentialProvider, buildClientSettingEndpoint(credentialProvider,
clientConfig, clientConfig,
endpoint, endpoint,
serviceName,
regionId), regionId),
describeStreamBackoffTimeInMillis, maxDescribeStreamRetryAttempts); describeStreamBackoffTimeInMillis, maxDescribeStreamRetryAttempts);
@ -130,10 +129,10 @@ public class KinesisProxyFactory implements IKinesisProxyFactory {
private static AmazonKinesisClient buildClientSettingEndpoint(AWSCredentialsProvider credentialProvider, private static AmazonKinesisClient buildClientSettingEndpoint(AWSCredentialsProvider credentialProvider,
ClientConfiguration clientConfig, ClientConfiguration clientConfig,
String endpoint, String endpoint,
String serviceName,
String regionId) { String regionId) {
AmazonKinesisClient client = new AmazonKinesisClient(credentialProvider, clientConfig); AmazonKinesisClient client = new AmazonKinesisClient(credentialProvider, clientConfig);
client.setEndpoint(endpoint, serviceName, regionId); client.setRegion(Region.getRegion(Regions.fromName(regionId)));
client.setEndpoint(endpoint);
return client; return client;
} }
} }

View file

@ -14,11 +14,11 @@
*/ */
package com.amazonaws.services.kinesis.leases.impl; package com.amazonaws.services.kinesis.leases.impl;
import com.amazonaws.util.json.Jackson;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import com.amazonaws.util.json.JSONObject;
/** /**
* This class contains data pertaining to a Lease. Distributed systems may use leases to partition work across a * This class contains data pertaining to a Lease. Distributed systems may use leases to partition work across a
* fleet of workers. Each unit of work (identified by a leaseKey) has a corresponding Lease. Every worker will contend * fleet of workers. Each unit of work (identified by a leaseKey) has a corresponding Lease. Every worker will contend
@ -226,7 +226,7 @@ public class Lease {
@Override @Override
public String toString() { public String toString() {
return new JSONObject(this).toString(); return Jackson.toJsonPrettyString(this);
} }
/** /**