diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/DrainChildSTDERRTask.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/DrainChildSTDERRTask.java similarity index 60% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/DrainChildSTDERRTask.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/DrainChildSTDERRTask.java index 7276b229..c6be4442 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/DrainChildSTDERRTask.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/DrainChildSTDERRTask.java @@ -1,18 +1,18 @@ /* - * Copyright 2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved. * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at + * Licensed under the Amazon Software License (the "License"). + * You may not use this file except in compliance with the License. + * A copy of the License is located at * - * http://aws.amazon.com/asl/ + * http://aws.amazon.com/asl/ * - * or in the "license" file accompanying this file. This file is distributed - * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either - * express or implied. See the License for the specific language governing - * permissions and limitations under the License. + * or in the "license" file accompanying this file. This file is distributed + * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either + * express or implied. See the License for the specific language governing + * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.BufferedReader; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/DrainChildSTDOUTTask.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/DrainChildSTDOUTTask.java similarity index 97% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/DrainChildSTDOUTTask.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/DrainChildSTDOUTTask.java index 0e95a14e..089c2739 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/DrainChildSTDOUTTask.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/DrainChildSTDOUTTask.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.BufferedReader; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/GetNextMessageTask.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/GetNextMessageTask.java similarity index 96% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/GetNextMessageTask.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/GetNextMessageTask.java index 8177a8d2..f55b1e72 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/GetNextMessageTask.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/GetNextMessageTask.java @@ -12,12 +12,12 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.BufferedReader; import java.io.IOException; -import com.amazonaws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.Message; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.extern.slf4j.Slf4j; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/LineReaderTask.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/LineReaderTask.java similarity index 99% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/LineReaderTask.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/LineReaderTask.java index 1f9910a8..e0e664b2 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/LineReaderTask.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/LineReaderTask.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.BufferedReader; import java.io.IOException; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MessageReader.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MessageReader.java similarity index 87% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MessageReader.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MessageReader.java index 71fbbd05..9a7d2c92 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MessageReader.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MessageReader.java @@ -1,18 +1,18 @@ /* - * Copyright 2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved. * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at + * Licensed under the Amazon Software License (the "License"). + * You may not use this file except in compliance with the License. + * A copy of the License is located at * - * http://aws.amazon.com/asl/ + * http://aws.amazon.com/asl/ * - * or in the "license" file accompanying this file. This file is distributed - * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either - * express or implied. See the License for the specific language governing - * permissions and limitations under the License. + * or in the "license" file accompanying this file. This file is distributed + * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either + * express or implied. See the License for the specific language governing + * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.BufferedReader; import java.io.InputStream; @@ -20,7 +20,7 @@ import java.io.InputStreamReader; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; -import com.amazonaws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.Message; import com.fasterxml.jackson.databind.ObjectMapper; /** diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MessageWriter.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MessageWriter.java similarity index 93% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MessageWriter.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MessageWriter.java index f5b6dd05..8480fed8 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MessageWriter.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MessageWriter.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.BufferedWriter; import java.io.IOException; @@ -25,12 +25,12 @@ import java.util.concurrent.Future; import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownReason; import software.amazon.aws.services.kinesis.clientlibrary.types.InitializationInput; import software.amazon.aws.services.kinesis.clientlibrary.types.ProcessRecordsInput; -import com.amazonaws.services.kinesis.multilang.messages.CheckpointMessage; -import com.amazonaws.services.kinesis.multilang.messages.InitializeMessage; -import com.amazonaws.services.kinesis.multilang.messages.Message; -import com.amazonaws.services.kinesis.multilang.messages.ProcessRecordsMessage; -import com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage; -import com.amazonaws.services.kinesis.multilang.messages.ShutdownRequestedMessage; +import software.amazon.aws.services.kinesis.multilang.messages.CheckpointMessage; +import software.amazon.aws.services.kinesis.multilang.messages.InitializeMessage; +import software.amazon.aws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.ProcessRecordsMessage; +import software.amazon.aws.services.kinesis.multilang.messages.ShutdownMessage; +import software.amazon.aws.services.kinesis.multilang.messages.ShutdownRequestedMessage; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.extern.slf4j.Slf4j; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemon.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangDaemon.java similarity index 99% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemon.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangDaemon.java index cc249101..80a040c3 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemon.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangDaemon.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.IOException; import java.io.PrintStream; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfig.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangDaemonConfig.java similarity index 98% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfig.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangDaemonConfig.java index fae5ca93..9b05a36a 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfig.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangDaemonConfig.java @@ -5,7 +5,7 @@ * BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific * language governing permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.File; import java.io.FileInputStream; @@ -20,7 +20,7 @@ import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration; -import com.amazonaws.services.kinesis.multilang.config.KinesisClientLibConfigurator; +import software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibConfigurator; import com.google.common.util.concurrent.ThreadFactoryBuilder; import lombok.extern.slf4j.Slf4j; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocol.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangProtocol.java similarity index 95% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocol.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangProtocol.java index 6e74c52f..85de40e3 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocol.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangProtocol.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.util.Optional; import java.util.concurrent.ExecutionException; @@ -26,13 +26,13 @@ import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClie import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownReason; import software.amazon.aws.services.kinesis.clientlibrary.types.InitializationInput; import software.amazon.aws.services.kinesis.clientlibrary.types.ProcessRecordsInput; -import com.amazonaws.services.kinesis.multilang.messages.CheckpointMessage; -import com.amazonaws.services.kinesis.multilang.messages.InitializeMessage; -import com.amazonaws.services.kinesis.multilang.messages.Message; -import com.amazonaws.services.kinesis.multilang.messages.ProcessRecordsMessage; -import com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage; -import com.amazonaws.services.kinesis.multilang.messages.ShutdownRequestedMessage; -import com.amazonaws.services.kinesis.multilang.messages.StatusMessage; +import software.amazon.aws.services.kinesis.multilang.messages.CheckpointMessage; +import software.amazon.aws.services.kinesis.multilang.messages.InitializeMessage; +import software.amazon.aws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.ProcessRecordsMessage; +import software.amazon.aws.services.kinesis.multilang.messages.ShutdownMessage; +import software.amazon.aws.services.kinesis.multilang.messages.ShutdownRequestedMessage; +import software.amazon.aws.services.kinesis.multilang.messages.StatusMessage; import lombok.extern.slf4j.Slf4j; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessor.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangRecordProcessor.java similarity index 99% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessor.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangRecordProcessor.java index b6652410..4534b19b 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessor.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangRecordProcessor.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.io.IOException; import java.io.InputStream; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessorFactory.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangRecordProcessorFactory.java similarity index 98% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessorFactory.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangRecordProcessorFactory.java index 817dada7..a9e1c611 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessorFactory.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangRecordProcessorFactory.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; import java.util.concurrent.ExecutorService; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java similarity index 98% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java index 4fe484d5..b408cb5c 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.lang.reflect.Constructor; import java.util.ArrayList; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/BooleanPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/BooleanPropertyValueDecoder.java similarity index 95% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/BooleanPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/BooleanPropertyValueDecoder.java index e57413dd..6e44645a 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/BooleanPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/BooleanPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.util.Arrays; import java.util.List; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/ClientConfigurationPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/ClientConfigurationPropertyValueDecoder.java similarity index 95% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/ClientConfigurationPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/ClientConfigurationPropertyValueDecoder.java index 43d89ce9..3ddcc987 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/ClientConfigurationPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/ClientConfigurationPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.util.Arrays; import java.util.List; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/IPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/IPropertyValueDecoder.java similarity index 94% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/IPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/IPropertyValueDecoder.java index bc23b18b..923efd19 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/IPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/IPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.util.List; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/InitialPositionInStreamPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/InitialPositionInStreamPropertyValueDecoder.java similarity index 95% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/InitialPositionInStreamPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/InitialPositionInStreamPropertyValueDecoder.java index bdc7ba7a..ce2d795a 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/InitialPositionInStreamPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/InitialPositionInStreamPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.util.Arrays; import java.util.List; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/IntegerPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/IntegerPropertyValueDecoder.java similarity index 95% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/IntegerPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/IntegerPropertyValueDecoder.java index 012ea2b6..90042b39 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/IntegerPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/IntegerPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.util.Arrays; import java.util.List; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfigurator.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/KinesisClientLibConfigurator.java similarity index 99% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfigurator.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/KinesisClientLibConfigurator.java index 04d688dd..f7d93155 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfigurator.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/KinesisClientLibConfigurator.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.io.IOException; import java.io.InputStream; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/LongPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/LongPropertyValueDecoder.java similarity index 95% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/LongPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/LongPropertyValueDecoder.java index 1382b153..89c5c091 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/LongPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/LongPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.util.Arrays; import java.util.List; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/SetPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/SetPropertyValueDecoder.java similarity index 96% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/SetPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/SetPropertyValueDecoder.java index 6dfe2dbe..25eeb243 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/SetPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/SetPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.util.Arrays; import java.util.HashSet; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/StringPropertyValueDecoder.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/StringPropertyValueDecoder.java similarity index 95% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/StringPropertyValueDecoder.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/StringPropertyValueDecoder.java index d5cc0482..289553ee 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/StringPropertyValueDecoder.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/StringPropertyValueDecoder.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.config; +package software.amazon.aws.services.kinesis.multilang.config; import java.util.Arrays; import java.util.List; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/CheckpointMessage.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/CheckpointMessage.java similarity index 97% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/CheckpointMessage.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/CheckpointMessage.java index f38980ba..ad5c76f5 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/CheckpointMessage.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/CheckpointMessage.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.messages; +package software.amazon.aws.services.kinesis.multilang.messages; import lombok.Getter; import lombok.Setter; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/InitializeMessage.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/InitializeMessage.java similarity index 96% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/InitializeMessage.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/InitializeMessage.java index 11e7e77a..2c57feea 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/InitializeMessage.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/InitializeMessage.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.messages; +package software.amazon.aws.services.kinesis.multilang.messages; import software.amazon.aws.services.kinesis.clientlibrary.types.InitializationInput; import lombok.Getter; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/JsonFriendlyRecord.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/JsonFriendlyRecord.java similarity index 96% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/JsonFriendlyRecord.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/JsonFriendlyRecord.java index 445d51a9..ae2f7a11 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/JsonFriendlyRecord.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/JsonFriendlyRecord.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.messages; +package software.amazon.aws.services.kinesis.multilang.messages; import java.util.Date; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/Message.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/Message.java similarity index 97% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/Message.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/Message.java index 7470b8e2..8bb3d367 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/Message.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/Message.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.messages; +package software.amazon.aws.services.kinesis.multilang.messages; import com.fasterxml.jackson.annotation.JsonSubTypes; import com.fasterxml.jackson.annotation.JsonTypeInfo; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ProcessRecordsMessage.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ProcessRecordsMessage.java similarity index 96% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ProcessRecordsMessage.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ProcessRecordsMessage.java index ccd5b702..99feeef2 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ProcessRecordsMessage.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ProcessRecordsMessage.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.messages; +package software.amazon.aws.services.kinesis.multilang.messages; import java.util.ArrayList; import java.util.List; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownMessage.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ShutdownMessage.java similarity index 63% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownMessage.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ShutdownMessage.java index 3ae5756f..2236f645 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownMessage.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ShutdownMessage.java @@ -1,18 +1,18 @@ /* - * Copyright 2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved. * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at + * Licensed under the Amazon Software License (the "License"). + * You may not use this file except in compliance with the License. + * A copy of the License is located at * - * http://aws.amazon.com/asl/ + * http://aws.amazon.com/asl/ * - * or in the "license" file accompanying this file. This file is distributed - * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either - * express or implied. See the License for the specific language governing - * permissions and limitations under the License. + * or in the "license" file accompanying this file. This file is distributed + * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either + * express or implied. See the License for the specific language governing + * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.messages; +package software.amazon.aws.services.kinesis.multilang.messages; import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownReason; diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java similarity index 93% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java index 409cbce4..19f694a0 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java @@ -12,7 +12,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.messages; +package software.amazon.aws.services.kinesis.multilang.messages; /** * A message to indicate to the client's process that shutdown is requested. diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/StatusMessage.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/StatusMessage.java similarity index 61% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/StatusMessage.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/StatusMessage.java index 5ea5aa75..69b3b803 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/StatusMessage.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/StatusMessage.java @@ -1,18 +1,18 @@ /* - * Copyright 2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved. * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at + * Licensed under the Amazon Software License (the "License"). + * You may not use this file except in compliance with the License. + * A copy of the License is located at * - * http://aws.amazon.com/asl/ + * http://aws.amazon.com/asl/ * - * or in the "license" file accompanying this file. This file is distributed - * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either - * express or implied. See the License for the specific language governing - * permissions and limitations under the License. + * or in the "license" file accompanying this file. This file is distributed + * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either + * express or implied. See the License for the specific language governing + * permissions and limitations under the License. */ -package com.amazonaws.services.kinesis.multilang.messages; +package software.amazon.aws.services.kinesis.multilang.messages; /** * A message sent by the client's process to indicate to the record processor that it completed a particular action. diff --git a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/package-info.java b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/package-info.java similarity index 88% rename from amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/package-info.java rename to amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/package-info.java index 2ec96e40..893c59ad 100644 --- a/amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/package-info.java +++ b/amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/package-info.java @@ -1,16 +1,16 @@ /* - * Copyright 2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved. * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at + * Licensed under the Amazon Software License (the "License"). + * You may not use this file except in compliance with the License. + * A copy of the License is located at * - * http://aws.amazon.com/asl/ + * http://aws.amazon.com/asl/ * - * or in the "license" file accompanying this file. This file is distributed - * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either - * express or implied. See the License for the specific language governing - * permissions and limitations under the License. + * or in the "license" file accompanying this file. This file is distributed + * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either + * express or implied. See the License for the specific language governing + * permissions and limitations under the License. */ /** * This package provides a KCL application which implements the multi language protocol. The multi language protocol @@ -121,5 +121,5 @@ * href="https://docs.python.org/2/library/base64.html">base64 module. * */ -package com.amazonaws.services.kinesis.multilang; +package software.amazon.aws.services.kinesis.multilang; diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageReaderTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageReaderTest.java index a30f3516..ddea7203 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageReaderTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageReaderTest.java @@ -31,9 +31,10 @@ import org.mockito.Mockito; import org.mockito.invocation.InvocationOnMock; import org.mockito.stubbing.Answer; -import com.amazonaws.services.kinesis.multilang.messages.Message; -import com.amazonaws.services.kinesis.multilang.messages.StatusMessage; +import software.amazon.aws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.StatusMessage; import com.fasterxml.jackson.databind.ObjectMapper; +import software.amazon.aws.services.kinesis.multilang.MessageReader; public class MessageReaderTest { diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageWriterTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageWriterTest.java index 6a7b6e9b..5e369771 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageWriterTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageWriterTest.java @@ -32,9 +32,10 @@ import org.mockito.Mockito; import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownReason; import com.amazonaws.services.kinesis.model.Record; -import com.amazonaws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.Message; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; +import software.amazon.aws.services.kinesis.multilang.MessageWriter; public class MessageWriterTest { diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfigTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfigTest.java index 130727a1..e434e025 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfigTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfigTest.java @@ -27,8 +27,9 @@ import org.mockito.Mockito; import com.amazonaws.auth.AWSCredentials; import com.amazonaws.auth.AWSCredentialsProvider; -import com.amazonaws.services.kinesis.multilang.config.KinesisClientLibConfigurator; +import software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibConfigurator; import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration; +import software.amazon.aws.services.kinesis.multilang.MultiLangDaemonConfig; public class MultiLangDaemonConfigTest { diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonTest.java index 18bab6aa..d18b8b36 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonTest.java @@ -23,6 +23,8 @@ import org.mockito.Mockito; import com.amazonaws.auth.AWSCredentials; import com.amazonaws.auth.AWSCredentialsProvider; import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration; +import software.amazon.aws.services.kinesis.multilang.MultiLangDaemon; +import software.amazon.aws.services.kinesis.multilang.MultiLangRecordProcessorFactory; public class MultiLangDaemonTest { diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocolTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocolTest.java index 1c128f40..53ff651d 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocolTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocolTest.java @@ -24,10 +24,10 @@ import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownRea import software.amazon.aws.services.kinesis.clientlibrary.types.InitializationInput; import software.amazon.aws.services.kinesis.clientlibrary.types.ProcessRecordsInput; import com.amazonaws.services.kinesis.model.Record; -import com.amazonaws.services.kinesis.multilang.messages.CheckpointMessage; -import com.amazonaws.services.kinesis.multilang.messages.Message; -import com.amazonaws.services.kinesis.multilang.messages.ProcessRecordsMessage; -import com.amazonaws.services.kinesis.multilang.messages.StatusMessage; +import software.amazon.aws.services.kinesis.multilang.messages.CheckpointMessage; +import software.amazon.aws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.ProcessRecordsMessage; +import software.amazon.aws.services.kinesis.multilang.messages.StatusMessage; import com.google.common.util.concurrent.SettableFuture; import org.junit.Before; import org.junit.Test; @@ -37,6 +37,9 @@ import org.mockito.Mockito; import org.mockito.invocation.InvocationOnMock; import org.mockito.runners.MockitoJUnitRunner; import org.mockito.stubbing.Answer; +import software.amazon.aws.services.kinesis.multilang.MessageReader; +import software.amazon.aws.services.kinesis.multilang.MessageWriter; +import software.amazon.aws.services.kinesis.multilang.MultiLangProtocol; import java.util.ArrayList; import java.util.Collections; diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/ReadSTDERRTaskTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/ReadSTDERRTaskTest.java index 55e96365..bbe53acf 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/ReadSTDERRTaskTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/ReadSTDERRTaskTest.java @@ -27,6 +27,8 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; import org.mockito.Mockito; +import software.amazon.aws.services.kinesis.multilang.DrainChildSTDERRTask; +import software.amazon.aws.services.kinesis.multilang.LineReaderTask; public class ReadSTDERRTaskTest { diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorFactoryTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorFactoryTest.java index d9a6265b..e731cd70 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorFactoryTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorFactoryTest.java @@ -22,6 +22,8 @@ import software.amazon.aws.services.kinesis.clientlibrary.interfaces.v2.IRecordP import org.junit.runner.RunWith; import org.mockito.Mock; import org.mockito.runners.MockitoJUnitRunner; +import software.amazon.aws.services.kinesis.multilang.MultiLangRecordProcessor; +import software.amazon.aws.services.kinesis.multilang.MultiLangRecordProcessorFactory; @RunWith(MockitoJUnitRunner.class) public class StreamingRecordProcessorFactoryTest { diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorTest.java index 376b5534..43244b8b 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorTest.java @@ -26,11 +26,11 @@ import software.amazon.aws.services.kinesis.clientlibrary.types.InitializationIn import software.amazon.aws.services.kinesis.clientlibrary.types.ProcessRecordsInput; import software.amazon.aws.services.kinesis.clientlibrary.types.ShutdownInput; import com.amazonaws.services.kinesis.model.Record; -import com.amazonaws.services.kinesis.multilang.messages.InitializeMessage; -import com.amazonaws.services.kinesis.multilang.messages.Message; -import com.amazonaws.services.kinesis.multilang.messages.ProcessRecordsMessage; -import com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage; -import com.amazonaws.services.kinesis.multilang.messages.StatusMessage; +import software.amazon.aws.services.kinesis.multilang.messages.InitializeMessage; +import software.amazon.aws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.ProcessRecordsMessage; +import software.amazon.aws.services.kinesis.multilang.messages.ShutdownMessage; +import software.amazon.aws.services.kinesis.multilang.messages.StatusMessage; import com.fasterxml.jackson.databind.ObjectMapper; import org.junit.Assert; import org.junit.Before; @@ -41,6 +41,10 @@ import org.mockito.Mockito; import org.mockito.invocation.InvocationOnMock; import org.mockito.runners.MockitoJUnitRunner; import org.mockito.stubbing.Answer; +import software.amazon.aws.services.kinesis.multilang.DrainChildSTDERRTask; +import software.amazon.aws.services.kinesis.multilang.MessageReader; +import software.amazon.aws.services.kinesis.multilang.MessageWriter; +import software.amazon.aws.services.kinesis.multilang.MultiLangRecordProcessor; import java.io.IOException; import java.io.InputStream; diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoderTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoderTest.java index ae05d579..16029a84 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoderTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoderTest.java @@ -22,6 +22,7 @@ import com.amazonaws.auth.AWSCredentials; import com.amazonaws.auth.BasicAWSCredentials; import com.amazonaws.auth.AWSCredentialsProvider; import com.amazonaws.auth.AWSCredentialsProviderChain; +import software.amazon.aws.services.kinesis.multilang.config.AWSCredentialsProviderPropertyValueDecoder; public class AWSCredentialsProviderPropertyValueDecoderTest { diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfiguratorTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfiguratorTest.java index d7144979..e2a2fe1e 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfiguratorTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfiguratorTest.java @@ -34,6 +34,7 @@ import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPosi import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration; import software.amazon.aws.services.kinesis.metrics.interfaces.MetricsLevel; import com.google.common.collect.ImmutableSet; +import software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibConfigurator; public class KinesisClientLibConfiguratorTest { diff --git a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/messages/MessageTest.java b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/messages/MessageTest.java index 8ab5847a..1f77e734 100644 --- a/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/messages/MessageTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/messages/MessageTest.java @@ -26,6 +26,14 @@ import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownRea import com.amazonaws.services.kinesis.model.Record; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; +import software.amazon.aws.services.kinesis.multilang.messages.CheckpointMessage; +import software.amazon.aws.services.kinesis.multilang.messages.InitializeMessage; +import software.amazon.aws.services.kinesis.multilang.messages.JsonFriendlyRecord; +import software.amazon.aws.services.kinesis.multilang.messages.Message; +import software.amazon.aws.services.kinesis.multilang.messages.ProcessRecordsMessage; +import software.amazon.aws.services.kinesis.multilang.messages.ShutdownMessage; +import software.amazon.aws.services.kinesis.multilang.messages.ShutdownRequestedMessage; +import software.amazon.aws.services.kinesis.multilang.messages.StatusMessage; public class MessageTest {