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

Updating the java packages for src/main/java for multilang from com.amazonaws.services.kinesis to software.amazon.aws.services.kinesis.

Browse source
This commit is contained in:
Sahil Palvia 2018-03-13 15:37:25 -07:00
parent 60aa89b7cd
commit 383dae97e1
41 changed files with 130 additions and 104 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/DrainChildSTDERRTask.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/DrainChildSTDERRTask.java
View file

@ -1,5 +1,5 @@
/*
* 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.
@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/DrainChildSTDOUTTask.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/DrainChildSTDOUTTask.java
View file

@ -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;

4
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/GetNextMessageTask.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/GetNextMessageTask.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/LineReaderTask.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/LineReaderTask.java
View file

@ -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;

6
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MessageReader.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MessageReader.java
View file

@ -1,5 +1,5 @@
/*
* 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.
@ -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.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;
/**

14
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MessageWriter.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MessageWriter.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemon.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangDaemon.java
View file

@ -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;

4
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfig.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangDaemonConfig.java
View file

@ -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;

16
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocol.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangProtocol.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessor.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangRecordProcessor.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessorFactory.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/MultiLangRecordProcessorFactory.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/BooleanPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/BooleanPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/ClientConfigurationPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/ClientConfigurationPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/IPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/IPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/InitialPositionInStreamPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/InitialPositionInStreamPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/IntegerPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/IntegerPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfigurator.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/KinesisClientLibConfigurator.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/LongPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/LongPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/SetPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/SetPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/config/StringPropertyValueDecoder.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/config/StringPropertyValueDecoder.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/CheckpointMessage.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/CheckpointMessage.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/InitializeMessage.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/InitializeMessage.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/JsonFriendlyRecord.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/JsonFriendlyRecord.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/Message.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/Message.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ProcessRecordsMessage.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ProcessRecordsMessage.java
View file

@ -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;

4
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownMessage.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ShutdownMessage.java
View file

@ -1,5 +1,5 @@
/*
* 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.
@ -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.lib.worker.ShutdownReason;

2
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java
View file

@ -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.

4
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/messages/StatusMessage.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/messages/StatusMessage.java
View file

@ -1,5 +1,5 @@
/*
* 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.
@ -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 sent by the client's process to indicate to the record processor that it completed a particular action.

4
amazon-kinesis-client-multilang/src/main/java/com/amazonaws/services/kinesis/multilang/package-info.java → amazon-kinesis-client-multilang/src/main/java/software/amazon/aws/services/kinesis/multilang/package-info.java
View file

@ -1,5 +1,5 @@
/*
* 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.
@ -121,5 +121,5 @@
* href="https://docs.python.org/2/library/base64.html">base64</a> module.
*
*/
package com.amazonaws.services.kinesis.multilang;
package software.amazon.aws.services.kinesis.multilang;

5
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageReaderTest.java
View file

@ -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 {

3
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MessageWriterTest.java
View file

@ -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 {

3
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonConfigTest.java
View file

@ -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 {

2
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangDaemonTest.java
View file

@ -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 {

11
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocolTest.java
View file

@ -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;

2
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/ReadSTDERRTaskTest.java
View file

@ -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 {

2
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorFactoryTest.java
View file

@ -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 {

14
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/StreamingRecordProcessorTest.java
View file

@ -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;

1
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoderTest.java
View file

@ -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 {

1
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfiguratorTest.java
View file

@ -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 {

8
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/messages/MessageTest.java
View file

@ -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 {