diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java index cca09c44..2d5f80ad 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java @@ -228,6 +228,80 @@ public class Worker implements Runnable { execService); } + // Backwards compatible constructors + /** + * This constructor is for binary compatibility with code compiled against version of the KCL that only have + * constructors taking "Client" objects. + * + * @param recordProcessorFactory + * Used to get record processor instances for processing data from shards + * @param config + * Kinesis Client Library configuration + * @param kinesisClient + * Kinesis Client used for fetching data + * @param dynamoDBClient + * DynamoDB client used for checkpoints and tracking leases + * @param cloudWatchClient + * CloudWatch Client for publishing metrics + */ + public Worker( + com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory recordProcessorFactory, + KinesisClientLibConfiguration config, AmazonKinesisClient kinesisClient, + AmazonDynamoDBClient dynamoDBClient, AmazonCloudWatchClient cloudWatchClient) { + this(recordProcessorFactory, config, (AmazonKinesis) kinesisClient, (AmazonDynamoDB) dynamoDBClient, + (AmazonCloudWatch) cloudWatchClient); + } + + /** + * This constructor is for binary compatibility with code compiled against version of the KCL that only have + * constructors taking "Client" objects. + * + * @param recordProcessorFactory + * Used to get record processor instances for processing data from shards + * @param config + * Kinesis Client Library configuration + * @param kinesisClient + * Kinesis Client used for fetching data + * @param dynamoDBClient + * DynamoDB client used for checkpoints and tracking leases + * @param cloudWatchClient + * CloudWatch Client for publishing metrics + * @param execService + * ExecutorService to use for processing records (support for multi-threaded consumption) + */ + public Worker( + com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory recordProcessorFactory, + KinesisClientLibConfiguration config, AmazonKinesisClient kinesisClient, + AmazonDynamoDBClient dynamoDBClient, AmazonCloudWatchClient cloudWatchClient, ExecutorService execService) { + this(recordProcessorFactory, config, (AmazonKinesis) kinesisClient, (AmazonDynamoDB) dynamoDBClient, + (AmazonCloudWatch) cloudWatchClient, execService); + } + + /** + * This constructor is for binary compatibility with code compiled against version of the KCL that only have + * constructors taking "Client" objects. + * + * @param recordProcessorFactory + * Used to get record processor instances for processing data from shards + * @param config + * Kinesis Client Library configuration + * @param kinesisClient + * Kinesis Client used for fetching data + * @param dynamoDBClient + * DynamoDB client used for checkpoints and tracking leases + * @param metricsFactory + * Metrics factory used to emit metrics + * @param execService + * ExecutorService to use for processing records (support for multi-threaded consumption) + */ + public Worker( + com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory recordProcessorFactory, + KinesisClientLibConfiguration config, AmazonKinesisClient kinesisClient, + AmazonDynamoDBClient dynamoDBClient, IMetricsFactory metricsFactory, ExecutorService execService) { + this(recordProcessorFactory, config, (AmazonKinesis) kinesisClient, (AmazonDynamoDB) dynamoDBClient, + metricsFactory, execService); + } + /** * @param recordProcessorFactory * Used to get record processor instances for processing data from shards @@ -922,80 +996,6 @@ public class Worker implements Runnable { } } - // Backwards compatible constructors - /** - * This constructor is for binary compatibility with code compiled against version of the KCL that only have - * constructors taking "Client" objects. - * - * @param recordProcessorFactory - * Used to get record processor instances for processing data from shards - * @param config - * Kinesis Client Library configuration - * @param kinesisClient - * Kinesis Client used for fetching data - * @param dynamoDBClient - * DynamoDB client used for checkpoints and tracking leases - * @param cloudWatchClient - * CloudWatch Client for publishing metrics - */ - public Worker( - com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory recordProcessorFactory, - KinesisClientLibConfiguration config, AmazonKinesisClient kinesisClient, - AmazonDynamoDBClient dynamoDBClient, AmazonCloudWatchClient cloudWatchClient) { - this(recordProcessorFactory, config, (AmazonKinesis) kinesisClient, (AmazonDynamoDB) dynamoDBClient, - (AmazonCloudWatch) cloudWatchClient); - } - - /** - * This constructor is for binary compatibility with code compiled against version of the KCL that only have - * constructors taking "Client" objects. - * - * @param recordProcessorFactory - * Used to get record processor instances for processing data from shards - * @param config - * Kinesis Client Library configuration - * @param kinesisClient - * Kinesis Client used for fetching data - * @param dynamoDBClient - * DynamoDB client used for checkpoints and tracking leases - * @param cloudWatchClient - * CloudWatch Client for publishing metrics - * @param execService - * ExecutorService to use for processing records (support for multi-threaded consumption) - */ - public Worker( - com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory recordProcessorFactory, - KinesisClientLibConfiguration config, AmazonKinesisClient kinesisClient, - AmazonDynamoDBClient dynamoDBClient, AmazonCloudWatchClient cloudWatchClient, ExecutorService execService) { - this(recordProcessorFactory, config, (AmazonKinesis) kinesisClient, (AmazonDynamoDB) dynamoDBClient, - (AmazonCloudWatch) cloudWatchClient, execService); - } - - /** - * This constructor is for binary compatibility with code compiled against version of the KCL that only have - * constructors taking "Client" objects. - * - * @param recordProcessorFactory - * Used to get record processor instances for processing data from shards - * @param config - * Kinesis Client Library configuration - * @param kinesisClient - * Kinesis Client used for fetching data - * @param dynamoDBClient - * DynamoDB client used for checkpoints and tracking leases - * @param metricsFactory - * Metrics factory used to emit metrics - * @param execService - * ExecutorService to use for processing records (support for multi-threaded consumption) - */ - public Worker( - com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory recordProcessorFactory, - KinesisClientLibConfiguration config, AmazonKinesisClient kinesisClient, - AmazonDynamoDBClient dynamoDBClient, IMetricsFactory metricsFactory, ExecutorService execService) { - this(recordProcessorFactory, config, (AmazonKinesis) kinesisClient, (AmazonDynamoDB) dynamoDBClient, - metricsFactory, execService); - } - @VisibleForTesting StreamConfig getStreamConfig() { return streamConfig;