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

Updating the java packages for src/test/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:45:59 -07:00
parent 383dae97e1
commit 1d400ad853
12 changed files with 46 additions and 53 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang; package software.amazon.aws.services.kinesis.multilang;
import static org.hamcrest.CoreMatchers.equalTo; import static org.hamcrest.CoreMatchers.equalTo;
import static org.hamcrest.CoreMatchers.nullValue; import static org.hamcrest.CoreMatchers.nullValue;

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

@ -1,5 +1,5 @@
/* /*
* Copyright 2012-2016 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"). * Licensed under the Amazon Software License (the "License").
* You may not use this file except in compliance with 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 * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * 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.BufferedReader;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;

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

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * 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.IOException;
import java.io.OutputStream; import java.io.OutputStream;

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

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang; package software.amazon.aws.services.kinesis.multilang;
import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNotNull;

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

@ -1,5 +1,5 @@
/* /*
* Copyright 2012-2016 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"). * Licensed under the Amazon Software License (the "License").
* You may not use this file except in compliance with 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 * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang; package software.amazon.aws.services.kinesis.multilang;
import java.io.PrintStream; import java.io.PrintStream;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;

5
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocolTest.java → amazon-kinesis-client-multilang/src/test/java/software/amazon/aws/services/kinesis/multilang/MultiLangProtocolTest.java
View file

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang; package software.amazon.aws.services.kinesis.multilang;
import software.amazon.aws.services.kinesis.clientlibrary.exceptions.InvalidStateException; import software.amazon.aws.services.kinesis.clientlibrary.exceptions.InvalidStateException;
import software.amazon.aws.services.kinesis.clientlibrary.exceptions.KinesisClientLibDependencyException; import software.amazon.aws.services.kinesis.clientlibrary.exceptions.KinesisClientLibDependencyException;
@ -37,9 +37,6 @@ import org.mockito.Mockito;
import org.mockito.invocation.InvocationOnMock; import org.mockito.invocation.InvocationOnMock;
import org.mockito.runners.MockitoJUnitRunner; import org.mockito.runners.MockitoJUnitRunner;
import org.mockito.stubbing.Answer; 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.ArrayList;
import java.util.Collections; import java.util.Collections;

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

@ -1,5 +1,5 @@
/* /*
* Copyright 2012-2016 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"). * Licensed under the Amazon Software License (the "License").
* You may not use this file except in compliance with 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 * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * 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.BufferedReader;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;

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

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang; package software.amazon.aws.services.kinesis.multilang;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration; import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration;
import org.junit.Assert; import org.junit.Assert;

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

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang; package software.amazon.aws.services.kinesis.multilang;
import software.amazon.aws.services.kinesis.clientlibrary.exceptions.InvalidStateException; import software.amazon.aws.services.kinesis.clientlibrary.exceptions.InvalidStateException;
import software.amazon.aws.services.kinesis.clientlibrary.exceptions.KinesisClientLibDependencyException; import software.amazon.aws.services.kinesis.clientlibrary.exceptions.KinesisClientLibDependencyException;
@ -41,10 +41,6 @@ import org.mockito.Mockito;
import org.mockito.invocation.InvocationOnMock; import org.mockito.invocation.InvocationOnMock;
import org.mockito.runners.MockitoJUnitRunner; import org.mockito.runners.MockitoJUnitRunner;
import org.mockito.stubbing.Answer; 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.IOException;
import java.io.InputStream; import java.io.InputStream;

6
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoderTest.java → amazon-kinesis-client-multilang/src/test/java/software/amazon/aws/services/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoderTest.java
View file

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang.config; package software.amazon.aws.services.kinesis.multilang.config;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
@ -30,9 +30,9 @@ public class AWSCredentialsProviderPropertyValueDecoderTest {
private static final String TEST_SECRET_KEY = "456"; private static final String TEST_SECRET_KEY = "456";
private String credentialName1 = private String credentialName1 =
"com.amazonaws.services.kinesis.multilang.config.AWSCredentialsProviderPropertyValueDecoderTest$AlwaysSucceedCredentialsProvider"; "software.amazon.aws.services.kinesis.multilang.config.AWSCredentialsProviderPropertyValueDecoderTest$AlwaysSucceedCredentialsProvider";
private String credentialName2 = private String credentialName2 =
"com.amazonaws.services.kinesis.multilang.config.AWSCredentialsProviderPropertyValueDecoderTest$ConstructorCredentialsProvider"; "software.amazon.aws.services.kinesis.multilang.config.AWSCredentialsProviderPropertyValueDecoderTest$ConstructorCredentialsProvider";
private AWSCredentialsProviderPropertyValueDecoder decoder = new AWSCredentialsProviderPropertyValueDecoder(); private AWSCredentialsProviderPropertyValueDecoder decoder = new AWSCredentialsProviderPropertyValueDecoder();
@Test @Test

12
amazon-kinesis-client-multilang/src/test/java/com/amazonaws/services/kinesis/multilang/config/KinesisClientLibConfiguratorTest.java → amazon-kinesis-client-multilang/src/test/java/software/amazon/aws/services/kinesis/multilang/config/KinesisClientLibConfiguratorTest.java
View file

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang.config; package software.amazon.aws.services.kinesis.multilang.config;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertFalse;
@ -39,15 +39,15 @@ import software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibCon
public class KinesisClientLibConfiguratorTest { public class KinesisClientLibConfiguratorTest {
private String credentialName1 = private String credentialName1 =
"com.amazonaws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysSucceedCredentialsProvider"; "software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysSucceedCredentialsProvider";
private String credentialName2 = private String credentialName2 =
"com.amazonaws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysFailCredentialsProvider"; "software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysFailCredentialsProvider";
private String credentialNameKinesis = private String credentialNameKinesis =
"com.amazonaws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysSucceedCredentialsProviderKinesis"; "software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysSucceedCredentialsProviderKinesis";
private String credentialNameDynamoDB = private String credentialNameDynamoDB =
"com.amazonaws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysSucceedCredentialsProviderDynamoDB"; "software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysSucceedCredentialsProviderDynamoDB";
private String credentialNameCloudWatch = private String credentialNameCloudWatch =
"com.amazonaws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysSucceedCredentialsProviderCloudWatch"; "software.amazon.aws.services.kinesis.multilang.config.KinesisClientLibConfiguratorTest$AlwaysSucceedCredentialsProviderCloudWatch";
private KinesisClientLibConfigurator configurator = new KinesisClientLibConfigurator(); private KinesisClientLibConfigurator configurator = new KinesisClientLibConfigurator();
@Test @Test

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

@ -12,7 +12,7 @@
* express or implied. See the License for the specific language governing * express or implied. See the License for the specific language governing
* permissions and limitations under the License. * permissions and limitations under the License.
*/ */
package com.amazonaws.services.kinesis.multilang.messages; package software.amazon.aws.services.kinesis.multilang.messages;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.util.ArrayList; import java.util.ArrayList;