adding some unit tests.

src/main/java/com/amazonaws/services/kinesis/multilang/messages/ShutdownRequestedMessage.java

@@ -7,7 +7,7 @@ public class ShutdownRequestedMessage extends Message {
     /**
      * The name used for the action field in {@link Message}.
      */
-    public static final String ACTION = "shutdownrequested";
+    public static final String ACTION = "shutdownRequested";
 
     /**
      * Convenience constructor.

src/test/java/com/amazonaws/services/kinesis/multilang/MessageWriterTest.java

@@ -113,6 +113,16 @@ public class MessageWriterTest {
         Mockito.verify(this.stream, Mockito.atLeastOnce()).flush();
     }
 
+    @Test
+    public void writeShutdownRequestedMessageTest() throws IOException, InterruptedException, ExecutionException {
+        Future<Boolean> future = this.messageWriter.writeShutdownRequestedMessage();
+        future.get();
+
+        Mockito.verify(this.stream, Mockito.atLeastOnce()).write(Mockito.any(byte[].class), Mockito.anyInt(),
+                Mockito.anyInt());
+        Mockito.verify(this.stream, Mockito.atLeastOnce()).flush();
+    }
+
     @Test
     public void streamIOExceptionTest() throws IOException, InterruptedException, ExecutionException {
         Mockito.doThrow(IOException.class).when(stream).flush();

src/test/java/com/amazonaws/services/kinesis/multilang/MultiLangProtocolTest.java

@@ -114,6 +114,16 @@ public class MultiLangProtocolTest {
         assertThat(protocol.shutdown(null, ShutdownReason.ZOMBIE), equalTo(true));
     }
 
+    @Test
+    public void shutdownRequestedTest() {
+        when(messageWriter.writeShutdownRequestedMessage()).thenReturn(buildFuture(true));
+        when(messageReader.getNextMessageFromSTDOUT()).thenReturn(buildFuture(new StatusMessage("shutdownRequested"), Message.class));
+        Mockito.doReturn(buildFuture(true)).when(messageWriter)
+                .writeShutdownRequestedMessage();
+        Mockito.doReturn(buildFuture(new StatusMessage("shutdownRequested"))).when(messageReader).getNextMessageFromSTDOUT();
+        assertThat(protocol.shutdownRequested(null), equalTo(true));
+    }
+
     private Answer<Future<Message>> buildMessageAnswers(List<Message> messages) {
         return new Answer<Future<Message>>() {
 

src/test/java/com/amazonaws/services/kinesis/multilang/messages/MessageTest.java

@@ -44,7 +44,7 @@ public class MessageTest {
                                 });
                             }
                         })), new ShutdownMessage(ShutdownReason.ZOMBIE), new StatusMessage("processRecords"),
-                        new InitializeMessage(), new ProcessRecordsMessage() };
+                        new InitializeMessage(), new ProcessRecordsMessage(), new ShutdownRequestedMessage() };
 
         for (int i = 0; i < messages.length; i++) {
             Assert.assertTrue("Each message should contain the action field", messages[i].toString().contains("action"));