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

Updating java package name under src/test/java for the client from com.amazonaws.services.kinesis to software.amazon.aws.services.kinesis.

Browse source
This commit is contained in:
Sahil Palvia 2018-03-13 15:27:07 -07:00
parent cc404eac97
commit 60aa89b7cd
56 changed files with 404 additions and 468 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/checkpoint/InMemoryCheckpointImplTest.java
View file

@ -1,38 +0,0 @@
/*
* Copyright 2012-2016 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
*
* 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.
*/
package com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint;
import org.junit.Before;
/**
* Test the InMemoryCheckpointImplTest class.
*/
public class InMemoryCheckpointImplTest extends CheckpointImplTestBase {
/**
* Constructor.
*/
public InMemoryCheckpointImplTest() {
super();
}
/**
* @throws java.lang.Exception
*/
@Before
public void setUp() throws Exception {
checkpoint = new InMemoryCheckpointImpl(startingSequenceNumber);
}
}

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/checkpoint/CheckpointImplTestBase.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/checkpoint/CheckpointImplTestBase.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.checkpoint;
package software.amazon.aws.services.kinesis.clientlibrary.lib.checkpoint;
import org.junit.After;
import org.junit.AfterClass;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/checkpoint/InMemoryCheckpointImpl.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/checkpoint/InMemoryCheckpointImpl.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.checkpoint;
package software.amazon.aws.services.kinesis.clientlibrary.lib.checkpoint;
import java.util.HashMap;
import java.util.Map;

38
amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/checkpoint/InMemoryCheckpointImplTest.java Normal file
View file

@ -0,0 +1,38 @@
/*
* 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
*
* 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.
*/
package software.amazon.aws.services.kinesis.clientlibrary.lib.checkpoint;
import org.junit.Before;
/**
* Test the InMemoryCheckpointImplTest class.
*/
public class InMemoryCheckpointImplTest extends CheckpointImplTestBase {
/**
* Constructor.
*/
public InMemoryCheckpointImplTest() {
super();
}
/**
* @throws java.lang.Exception
*/
@Before
public void setUp() throws Exception {
checkpoint = new InMemoryCheckpointImpl(startingSequenceNumber);
}
}

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/AsynchronousGetRecordsRetrievalStrategyIntegrationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/AsynchronousGetRecordsRetrievalStrategyIntegrationTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.hamcrest.CoreMatchers.nullValue;
import static org.hamcrest.MatcherAssert.assertThat;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/AsynchronousGetRecordsRetrievalStrategyTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/AsynchronousGetRecordsRetrievalStrategyTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.hamcrest.CoreMatchers.equalTo;
import static org.hamcrest.MatcherAssert.assertThat;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/BlockOnParentShardTaskTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/BlockOnParentShardTaskTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/BlockingGetRecordsCacheTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/BlockingGetRecordsCacheTest.java
View file

@ -13,7 +13,7 @@
* permissions and limitations under the License.
*/
package com.amazonaws.services.kinesis.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/CheckpointValueComparatorTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/CheckpointValueComparatorTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import junit.framework.Assert;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ConsumerStatesTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ConsumerStatesTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ConsumerStates.ConsumerState;
import static software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ConsumerStates.ShardConsumerState;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ExceptionThrowingLeaseManager.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ExceptionThrowingLeaseManager.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import java.util.Arrays;
import java.util.List;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/GracefulShutdownCoordinatorTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/GracefulShutdownCoordinatorTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.hamcrest.CoreMatchers.equalTo;
import static org.hamcrest.CoreMatchers.not;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfigurationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfigurationTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;

21
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibLeaseCoordinatorIntegrationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibLeaseCoordinatorIntegrationTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import java.util.ArrayList;
import java.util.Collections;
@ -30,7 +30,6 @@ import org.junit.Test;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClient;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibLeaseCoordinator;
import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber;
import software.amazon.aws.services.kinesis.leases.exceptions.DependencyException;
import software.amazon.aws.services.kinesis.leases.exceptions.InvalidStateException;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibLeaseCoordinatorTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibLeaseCoordinatorTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.mockito.Matchers.anyLong;
import static org.mockito.Mockito.doReturn;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisDataFetcherTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/KinesisDataFetcherTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.hamcrest.CoreMatchers.equalTo;
import static org.hamcrest.CoreMatchers.notNullValue;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ParentsFirstShardPrioritizationUnitTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ParentsFirstShardPrioritizationUnitTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.fail;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/PrefetchGetRecordsCacheIntegrationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/PrefetchGetRecordsCacheIntegrationTest.java
View file

@ -13,7 +13,7 @@
* permissions and limitations under the License.
*/
package com.amazonaws.services.kinesis.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/PrefetchGetRecordsCacheTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/PrefetchGetRecordsCacheTest.java
View file

@ -13,7 +13,7 @@
* permissions and limitations under the License.
*/
package com.amazonaws.services.kinesis.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotEquals;

17
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/PreparedCheckpointerTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/PreparedCheckpointerTest.java
View file

@ -1,4 +1,19 @@
package com.amazonaws.services.kinesis.clientlibrary.lib.worker;
/*
* 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
*
* 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.
*/
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.IPreparedCheckpointer;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ProcessTaskTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ProcessTaskTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;

26
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/RecordProcessorCheckpointerTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/RecordProcessorCheckpointerTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.fail;
@ -26,10 +26,6 @@ import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map.Entry;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.DoesNothingPreparedCheckpointer;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.RecordProcessorCheckpointer;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.SequenceNumberValidator;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardInfo;
import software.amazon.aws.services.kinesis.metrics.interfaces.IMetricsScope;
import org.junit.After;
import org.junit.Assert;
@ -42,7 +38,7 @@ import org.mockito.runners.MockitoJUnitRunner;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.ICheckpoint;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.IPreparedCheckpointer;
import com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint.InMemoryCheckpointImpl;
import software.amazon.aws.services.kinesis.clientlibrary.lib.checkpoint.InMemoryCheckpointImpl;
import software.amazon.aws.services.kinesis.clientlibrary.lib.checkpoint.SentinelCheckpoint;
import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber;
import software.amazon.aws.services.kinesis.clientlibrary.types.UserRecord;

17
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/RecordsFetcherFactoryTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/RecordsFetcherFactoryTest.java
View file

@ -1,4 +1,19 @@
package com.amazonaws.services.kinesis.clientlibrary.lib.worker;
/*
* 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
*
* 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.
*/
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.hamcrest.CoreMatchers.instanceOf;
import static org.hamcrest.MatcherAssert.assertThat;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SequenceNumberValidatorTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/SequenceNumberValidatorTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import junit.framework.Assert;

30
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardConsumerTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ShardConsumerTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.hamcrest.Matchers.equalTo;
import static org.hamcrest.Matchers.instanceOf;
@ -62,32 +62,10 @@ import org.mockito.runners.MockitoJUnitRunner;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.ICheckpoint;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor;
import software.amazon.aws.services.kinesis.clientlibrary.lib.checkpoint.Checkpoint;
import com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint.InMemoryCheckpointImpl;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.AsynchronousGetRecordsRetrievalStrategy;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.BlockingGetRecordsCache;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ConsumerStates;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.GetRecordsCache;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetrievalStrategy;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ITask;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitializeTask;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisDataFetcher;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.RecordProcessorCheckpointer;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.SequenceNumberValidator;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardConsumer;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardInfo;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownNotification;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownReason;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.StreamConfig;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.SynchronousGetRecordsRetrievalStrategy;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.TaskResult;
import software.amazon.aws.services.kinesis.clientlibrary.lib.checkpoint.InMemoryCheckpointImpl;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.IKinesisProxy;
import com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisLocalFileProxy;
import com.amazonaws.services.kinesis.clientlibrary.proxies.util.KinesisLocalFileDataCreator;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.KinesisLocalFileProxy;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.util.KinesisLocalFileDataCreator;
import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber;
import software.amazon.aws.services.kinesis.clientlibrary.types.InitializationInput;
import software.amazon.aws.services.kinesis.clientlibrary.types.ShutdownInput;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardInfoTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ShardInfoTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.hamcrest.CoreMatchers.equalTo;
import static org.hamcrest.CoreMatchers.is;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardObjectHelper.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ShardObjectHelper.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import java.math.BigInteger;
import java.util.ArrayList;

21
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSequenceVerifier.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ShardSequenceVerifier.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import java.util.ArrayList;
import java.util.Collections;
@ -25,7 +25,6 @@ import com.amazonaws.services.kinesis.model.Shard;
import junit.framework.Assert;
import lombok.extern.slf4j.Slf4j;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownReason;
/**
* Helper class to verify shard lineage in unit tests that use TestStreamlet.

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncTaskIntegrationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ShardSyncTaskIntegrationTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import java.util.HashSet;
import java.util.List;

29
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncerTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ShardSyncerTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import java.io.File;
import java.io.IOException;
@ -34,13 +34,10 @@ import org.junit.Test;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.local.embedded.DynamoDBEmbedded;
import software.amazon.aws.services.kinesis.clientlibrary.exceptions.internal.KinesisClientLibIOException;
import com.amazonaws.services.kinesis.clientlibrary.lib.worker.ExceptionThrowingLeaseManager.ExceptionThrowingLeaseManagerMethods;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardSyncer;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ExceptionThrowingLeaseManager.ExceptionThrowingLeaseManagerMethods;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.IKinesisProxy;
import com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisLocalFileProxy;
import com.amazonaws.services.kinesis.clientlibrary.proxies.util.KinesisLocalFileDataCreator;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.KinesisLocalFileProxy;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.util.KinesisLocalFileDataCreator;
import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber;
import software.amazon.aws.services.kinesis.leases.exceptions.DependencyException;
import software.amazon.aws.services.kinesis.leases.exceptions.InvalidStateException;

11
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownTaskTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ShutdownTaskTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
@ -31,15 +31,6 @@ import org.junit.Test;
import software.amazon.aws.services.kinesis.clientlibrary.exceptions.internal.KinesisClientLibIOException;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.GetRecordsCache;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.RecordProcessorCheckpointer;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardInfo;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownReason;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownTask;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.TaskResult;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.TaskType;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.IKinesisProxy;
import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLease;

21
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/TestStreamlet.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/TestStreamlet.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import java.util.ArrayList;
import java.util.HashSet;
@ -29,7 +29,6 @@ import software.amazon.aws.services.kinesis.clientlibrary.exceptions.ThrottlingE
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.v2.IShutdownNotificationAware;
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 software.amazon.aws.services.kinesis.clientlibrary.types.ShutdownInput;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/TestStreamletFactory.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/TestStreamletFactory.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import java.util.ArrayList;
import java.util.List;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ThrottlingReporterTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/ThrottlingReporterTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.mockito.Matchers.anyString;
import static org.mockito.Mockito.never;

36
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/WorkerTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/lib/worker/WorkerTest.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.clientlibrary.lib.worker;
package software.amazon.aws.services.kinesis.clientlibrary.lib.worker;
import static org.hamcrest.CoreMatchers.both;
import static org.hamcrest.CoreMatchers.equalTo;
@ -86,47 +86,19 @@ import software.amazon.aws.services.kinesis.clientlibrary.interfaces.ICheckpoint
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor;
import software.amazon.aws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessorFactory;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.BlockOnParentShardTask;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.GetRecordsCache;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetrievalStrategy;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.GracefulShutdownCoordinator;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ITask;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.InitializeTask;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibLeaseCoordinator;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.MetricsCollectingTaskDecorator;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.NoOpShardPrioritization;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.NoOpWorkerStateChangeListener;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardConsumer;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardInfo;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardPrioritization;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShardSyncer;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownNotificationTask;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownReason;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.ShutdownTask;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.StreamConfig;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.TaskResult;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.TaskType;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.V1ToV2RecordProcessorFactoryAdapter;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.Worker.WorkerCWMetricsFactory;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.Worker.WorkerThreadPoolExecutor;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.WorkerStateChangeListener;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.WorkerStateChangeListener.WorkerState;
import software.amazon.aws.services.kinesis.clientlibrary.lib.worker.Worker;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.IKinesisProxy;
import com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisLocalFileProxy;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.KinesisLocalFileProxy;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.KinesisProxy;
import com.amazonaws.services.kinesis.clientlibrary.proxies.util.KinesisLocalFileDataCreator;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.util.KinesisLocalFileDataCreator;
import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber;
import software.amazon.aws.services.kinesis.clientlibrary.types.InitializationInput;
import software.amazon.aws.services.kinesis.clientlibrary.types.ProcessRecordsInput;
import software.amazon.aws.services.kinesis.clientlibrary.types.ShutdownInput;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLease;
import com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseBuilder;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLeaseBuilder;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLeaseManager;
import software.amazon.aws.services.kinesis.leases.impl.LeaseManager;
import software.amazon.aws.services.kinesis.leases.interfaces.ILeaseManager;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisLocalFileProxy.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/proxies/KinesisLocalFileProxy.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.proxies;
package software.amazon.aws.services.kinesis.clientlibrary.proxies;
import java.io.BufferedReader;
import java.io.FileInputStream;

24
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisLocalFileProxyFactory.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/proxies/KinesisLocalFileProxyFactory.java
View file

@ -1,26 +1,24 @@
/*
* 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").
* 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.clientlibrary.proxies;
package software.amazon.aws.services.kinesis.clientlibrary.proxies;
import java.io.File;
import java.io.IOException;
import java.math.BigInteger;
import com.amazonaws.services.kinesis.clientlibrary.proxies.util.KinesisLocalFileDataCreator;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.IKinesisProxy;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.IKinesisProxyFactory;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.util.KinesisLocalFileDataCreator;
/** Factory for KinesisProxy objects that use a local file for data. Useful for testing purposes.
*

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxyTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/proxies/KinesisProxyTest.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.clientlibrary.proxies;
package software.amazon.aws.services.kinesis.clientlibrary.proxies;
import static org.hamcrest.Matchers.both;
import static org.hamcrest.Matchers.equalTo;

22
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.clientlibrary.proxies.util;
package software.amazon.aws.services.kinesis.clientlibrary.proxies.util;
import java.io.BufferedWriter;
import java.io.File;
@ -25,7 +25,7 @@ import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisLocalFileProxy;
import software.amazon.aws.services.kinesis.clientlibrary.proxies.KinesisLocalFileProxy;
import com.amazonaws.services.kinesis.model.HashKeyRange;
import com.amazonaws.services.kinesis.model.SequenceNumberRange;
import com.amazonaws.services.kinesis.model.Shard;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/clientlibrary/types/ShutdownReasonTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/clientlibrary/types/ShutdownReasonTest.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.clientlibrary.types;
package software.amazon.aws.services.kinesis.clientlibrary.types;
import static org.hamcrest.CoreMatchers.equalTo;
import static org.junit.Assert.assertThat;

3
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/KinesisClientLeaseBuilder.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/KinesisClientLeaseBuilder.java
View file

@ -12,14 +12,13 @@
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package com.amazonaws.services.kinesis.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import java.util.HashSet;
import java.util.Set;
import java.util.UUID;
import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLease;
public class KinesisClientLeaseBuilder {
private String leaseKey;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/LeaseCoordinatorExerciser.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/LeaseCoordinatorExerciser.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import java.awt.*;
import java.awt.event.ActionEvent;

2
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/LeaseIntegrationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/LeaseIntegrationTest.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.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import org.junit.Ignore;
import org.junit.Rule;

5
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/LeaseManagerIntegrationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/LeaseManagerIntegrationTest.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.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import java.util.Collection;
import java.util.List;
@ -23,9 +23,6 @@ import junit.framework.Assert;
import org.junit.Test;
import software.amazon.aws.services.kinesis.leases.exceptions.LeasingException;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLease;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLeaseManager;
import software.amazon.aws.services.kinesis.leases.impl.Lease;
public class LeaseManagerIntegrationTest extends LeaseIntegrationTest {

4
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/LeaseRenewerIntegrationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/LeaseRenewerIntegrationTest.java
View file

@ -12,12 +12,10 @@
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package com.amazonaws.services.kinesis.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber;
import software.amazon.aws.services.kinesis.leases.exceptions.LeasingException;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLease;
import software.amazon.aws.services.kinesis.leases.impl.LeaseRenewer;
import software.amazon.aws.services.kinesis.leases.interfaces.ILeaseRenewer;
import org.junit.Assert;
import org.junit.Before;

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/LeaseRenewerTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/LeaseRenewerTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import java.util.ArrayList;
import java.util.Arrays;

22
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/LeaseTakerIntegrationTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/LeaseTakerIntegrationTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import java.util.Map;
@ -21,8 +21,6 @@ import org.junit.Before;
import org.junit.Test;
import software.amazon.aws.services.kinesis.leases.exceptions.LeasingException;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLease;
import software.amazon.aws.services.kinesis.leases.impl.LeaseTaker;
public class LeaseTakerIntegrationTest extends LeaseIntegrationTest {

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/LeaseTakerTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/LeaseTakerTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import java.util.ArrayList;
import java.util.List;

5
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/leases/impl/TestHarnessBuilder.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/leases/impl/TestHarnessBuilder.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.leases.impl;
package software.amazon.aws.services.kinesis.leases.impl;
import java.util.ArrayList;
import java.util.Collections;
@ -27,9 +27,6 @@ import software.amazon.aws.services.kinesis.clientlibrary.types.ExtendedSequence
import software.amazon.aws.services.kinesis.leases.exceptions.DependencyException;
import software.amazon.aws.services.kinesis.leases.exceptions.InvalidStateException;
import software.amazon.aws.services.kinesis.leases.exceptions.LeasingException;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLease;
import software.amazon.aws.services.kinesis.leases.impl.KinesisClientLeaseManager;
import software.amazon.aws.services.kinesis.leases.impl.LeaseTaker;
import software.amazon.aws.services.kinesis.leases.interfaces.ILeaseRenewer;
public class TestHarnessBuilder {

21
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/metrics/impl/AccumulatingMetricsScopeTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/metrics/impl/AccumulatingMetricsScopeTest.java
View file

@ -1,25 +1,24 @@
/*
* 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").
* 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.metrics.impl;
package software.amazon.aws.services.kinesis.metrics.impl;
import org.junit.Assert;
import org.junit.Test;
import com.amazonaws.services.cloudwatch.model.MetricDatum;
import com.amazonaws.services.cloudwatch.model.StandardUnit;
import software.amazon.aws.services.kinesis.metrics.impl.AccumulateByNameMetricsScope;
public class AccumulatingMetricsScopeTest {

24
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/metrics/impl/CWPublisherRunnableTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/metrics/impl/CWPublisherRunnableTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.metrics.impl;
package software.amazon.aws.services.kinesis.metrics.impl;
import java.util.ArrayList;
import java.util.List;
@ -24,10 +24,6 @@ import org.mockito.Mockito;
import com.amazonaws.services.cloudwatch.model.MetricDatum;
import com.amazonaws.services.cloudwatch.model.StandardUnit;
import software.amazon.aws.services.kinesis.metrics.impl.CWMetricKey;
import software.amazon.aws.services.kinesis.metrics.impl.CWPublisherRunnable;
import software.amazon.aws.services.kinesis.metrics.impl.ICWMetricsPublisher;
import software.amazon.aws.services.kinesis.metrics.impl.MetricDatumWithKey;
public class CWPublisherRunnableTest {

23
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/metrics/impl/DefaultCWMetricsPublisherTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/metrics/impl/DefaultCWMetricsPublisherTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.metrics.impl;
package software.amazon.aws.services.kinesis.metrics.impl;
import java.util.ArrayList;
import java.util.HashMap;
@ -28,9 +28,6 @@ import com.amazonaws.services.cloudwatch.AmazonCloudWatch;
import com.amazonaws.services.cloudwatch.model.MetricDatum;
import com.amazonaws.services.cloudwatch.model.PutMetricDataRequest;
import com.amazonaws.services.cloudwatch.model.StandardUnit;
import software.amazon.aws.services.kinesis.metrics.impl.CWMetricKey;
import software.amazon.aws.services.kinesis.metrics.impl.DefaultCWMetricsPublisher;
import software.amazon.aws.services.kinesis.metrics.impl.MetricDatumWithKey;
public class DefaultCWMetricsPublisherTest {

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/metrics/impl/EndingMetricsScopeTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/metrics/impl/EndingMetricsScopeTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.metrics.impl;
package software.amazon.aws.services.kinesis.metrics.impl;
import org.junit.Test;

21
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/metrics/impl/FilteringMetricsScopeTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/metrics/impl/FilteringMetricsScopeTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.metrics.impl;
package software.amazon.aws.services.kinesis.metrics.impl;
import java.util.Set;
@ -25,7 +25,6 @@ import com.amazonaws.services.cloudwatch.model.StandardUnit;
import software.amazon.aws.services.kinesis.metrics.interfaces.IMetricsScope;
import software.amazon.aws.services.kinesis.metrics.interfaces.MetricsLevel;
import com.google.common.collect.ImmutableSet;
import software.amazon.aws.services.kinesis.metrics.impl.FilteringMetricsScope;
public class FilteringMetricsScopeTest {

23
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/metrics/impl/MetricAccumulatingQueueTest.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/metrics/impl/MetricAccumulatingQueueTest.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.metrics.impl;
package software.amazon.aws.services.kinesis.metrics.impl;
import java.util.Collection;
import java.util.Collections;
@ -25,9 +25,6 @@ import org.junit.Test;
import com.amazonaws.services.cloudwatch.model.Dimension;
import com.amazonaws.services.cloudwatch.model.MetricDatum;
import com.amazonaws.services.cloudwatch.model.StandardUnit;
import software.amazon.aws.services.kinesis.metrics.impl.CWMetricKey;
import software.amazon.aws.services.kinesis.metrics.impl.MetricAccumulatingQueue;
import software.amazon.aws.services.kinesis.metrics.impl.MetricDatumWithKey;
public class MetricAccumulatingQueueTest {

20
amazon-kinesis-client/src/test/java/com/amazonaws/services/kinesis/metrics/impl/TestHelper.java → amazon-kinesis-client/src/test/java/software/amazon/aws/services/kinesis/metrics/impl/TestHelper.java
View file

@ -1,18 +1,18 @@
/*
* 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").
* 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.metrics.impl;
package software.amazon.aws.services.kinesis.metrics.impl;
import com.amazonaws.services.cloudwatch.model.Dimension;
import com.amazonaws.services.cloudwatch.model.MetricDatum;