Merge pull request #11 from amcp/fixTest

Add DynamoDB Local dependency. Fix imports.

Author: Alexander Patrikalakis

.gitignore

@@ -1,2 +1,6 @@
 target/
 AwsCredentials.properties
+/.idea
+*.iml
+*~
+.*~

README.md

@@ -32,7 +32,7 @@ Add the following to your Maven pom file:
 <dependency>
     <groupId>com.amazonaws</groupId>
     <artifactId>dynamodb-streams-kinesis-adapter</artifactId>
-    <version>LATEST</version>
+    <version>1.2.1-SNAPSHOT</version>
 </dependency>
 ```
 

pom.xml

@@ -6,7 +6,7 @@
     <artifactId>dynamodb-streams-kinesis-adapter</artifactId>
     <packaging>jar</packaging>
     <name>DynamoDB Streams Adapter for Java</name>
-    <version>1.2.0</version>
+    <version>1.2.1-SNAPSHOT</version>
     <description>The DynamoDB Streams Adapter implements the AmazonKinesis interface so that your application can use KCL to consume and process data from a DynamoDB stream.</description>
     <url>https://aws.amazon.com/dynamodb</url>
 
@@ -25,6 +25,10 @@
     <properties>
         <aws-java-sdk.version>[1.11.115, 2.0.0)</aws-java-sdk.version>
         <amazon-kinesis-client.version>[1.7.5, 1.8.0)</amazon-kinesis-client.version>
+        <powermock.version>1.6.2</powermock.version>
+        <aws.dynamodblocal.version>1.11.86</aws.dynamodblocal.version>
+        <maven.dependency.version>3.0.0</maven.dependency.version>
+        <sqlite4java.version>1.0.392</sqlite4java.version>
         <gpg.skip>true</gpg.skip>
     </properties>
 
@@ -75,14 +79,14 @@
         <dependency>
             <groupId>org.powermock</groupId>
             <artifactId>powermock-module-junit4</artifactId>
-            <version>1.6.2</version>
+            <version>${powermock.version}</version>
             <scope>test</scope>
         </dependency>
 
         <dependency>
             <groupId>org.powermock</groupId>
             <artifactId>powermock-api-mockito</artifactId>
-            <version>1.6.2</version>
+            <version>${powermock.version}</version>
             <scope>test</scope>
         </dependency>
 
@@ -92,6 +96,13 @@
             <version>4.12</version>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>com.amazonaws</groupId>
+            <artifactId>DynamoDBLocal</artifactId>
+            <version>${aws.dynamodblocal.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <developers>
@@ -136,6 +147,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-gpg-plugin</artifactId>
+                <version>1.6</version>
                 <executions>
                     <execution>
                         <id>sign-artifacts</id>
@@ -158,9 +170,50 @@
                         <include>**/*Test.java</include>
                         <include>**/*Tests.java</include>
                     </includes>
+                    <argLine>-Dsqlite4java.library.path=${basedir}/target/dependencies</argLine>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-dependency-plugin</artifactId>
+                <version>${maven.dependency.version}</version>
+                <executions>
+                    <execution>
+                        <id>copy-dependencies</id>
+                        <phase>process-test-resources</phase>
+                        <goals>
+                            <goal>copy-dependencies</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>${project.build.directory}/dependencies</outputDirectory>
+                            <overWriteReleases>false</overWriteReleases>
+                            <overWriteSnapshots>false</overWriteSnapshots>
+                            <overWriteIfNewer>true</overWriteIfNewer>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
     </build>
 
+    <repositories>
+        <repository>
+            <id>dynamodblocal</id>
+            <name>AWS DynamoDB Local Release Repository</name>
+            <url>https://s3-us-west-2.amazonaws.com/dynamodb-local/release</url>
+            <snapshots>
+                <enabled>false</enabled>
+            </snapshots>
+        </repository>
+    </repositories>
+
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>com.almworks.sqlite4java</groupId>
+                <artifactId>sqlite4java</artifactId>
+                <version>${sqlite4java.version}</version>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
 </project>

src/test/java/com/amazonaws/services/dynamodbv2/streamsadapter/util/ReplicatingRecordProcessor.java

@@ -14,6 +14,8 @@
  */
 package com.amazonaws.services.dynamodbv2.streamsadapter.util;
 
+import static com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownReason.TERMINATE;
+
 import java.nio.charset.Charset;
 
 import org.apache.commons.logging.Log;
@@ -24,7 +26,6 @@
 import com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput;
 import com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput;
 import com.amazonaws.services.kinesis.clientlibrary.types.ShutdownInput;
-import com.amazonaws.services.kinesis.clientlibrary.types.ShutdownReason;
 import com.amazonaws.services.kinesis.model.Record;
 
 public class ReplicatingRecordProcessor implements IRecordProcessor {
@@ -81,7 +82,7 @@ public void processRecords(ProcessRecordsInput processRecordsInput) {
 
     @Override
     public void shutdown(ShutdownInput shutdownInput) {
-        if (ShutdownReason.TERMINATE.equals(shutdownInput.getShutdownReason())) {
+        if (TERMINATE.equals(shutdownInput.getShutdownReason())) {
             try {
                 shutdownInput.getCheckpointer().checkpoint();
             } catch (Exception e) {