Add support for SQS messages with a "Type" of "Binary"

See https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-attributes.html

Author: candrews

src/main/java/com/amazon/sqs/javamessaging/SQSMessagingClientConstants.java

@@ -36,6 +36,8 @@ public class SQSMessagingClientConstants {
      */
     public static final String STRING = "String";
 
+    public static final String BINARY = "Binary";
+
     public static final String NUMBER = "Number";
 
     public static final String INT = "Number.int";

src/main/java/com/amazon/sqs/javamessaging/message/SQSMessage.java

@@ -1191,7 +1191,7 @@ private static String getType(Object value) throws JMSException {
         }
 
         private static Object getObjectValue(String value, String type) throws JMSException {
-            if (STRING.equals(type) || NUMBER.equals(type)) {
+            if (STRING.equals(type) || NUMBER.equals(type) || BINARY.equals(type)) {
                 return value;
             } else if (INT.equals(type)) {
                 return Integer.valueOf(value);

src/test/java/com/amazon/sqs/javamessaging/message/SQSMessageTest.java

@@ -54,6 +54,7 @@ public class SQSMessageTest {
     final String myByte = "myByte";
     final String myString = "myString";
     final String myNumber = "myNumber";
+    final String myBinary = "myBinary";
 
     @Before
     public void setup() {
@@ -78,6 +79,7 @@ public void testProperty() throws JMSException {
         message.setByteProperty("myByteProperty", (byte) 'a');
         message.setStringProperty("myString", "StringValue");
         message.setStringProperty("myNumber", "500");
+        message.setStringProperty("myBinary", "binarydata");
 
         Assert.assertTrue(message.propertyExists("myTrueBoolean"));
         Assert.assertEquals(message.getObjectProperty("myTrueBoolean"), true);
@@ -124,6 +126,10 @@ public void testProperty() throws JMSException {
         Assert.assertEquals(message.getDoubleProperty("myNumber"), 500d);
         Assert.assertEquals(message.getIntProperty("myNumber"), 500);
 
+        Assert.assertTrue(message.propertyExists("myBinary"));
+        Assert.assertEquals(message.getObjectProperty("myBinary"), "binarydata");
+        Assert.assertEquals(message.getStringProperty("myBinary"), "binarydata");
+
         // Validate property names
         Set<String> propertyNamesSet = new HashSet<String>(Arrays.asList(
                 "myTrueBoolean",
@@ -135,6 +141,7 @@ public void testProperty() throws JMSException {
                 "myShort",
                 "myByteProperty",
                 "myNumber",
+                "myBinary",
                 "myString"));
 
         Enumeration<String > propertyNames = message.getPropertyNames();
@@ -155,6 +162,7 @@ public void testProperty() throws JMSException {
         Assert.assertFalse(message.propertyExists("myByteProperty"));
         Assert.assertFalse(message.propertyExists("myString"));
         Assert.assertFalse(message.propertyExists("myNumber"));
+        Assert.assertFalse(message.propertyExists("myBinary"));
 
         propertyNames = message.getPropertyNames();
         assertFalse(propertyNames.hasMoreElements());
@@ -330,6 +338,10 @@ public void testSQSMessageAttributeToProperty() throws JMSException {
                                                     .withDataType(SQSMessagingClientConstants.NUMBER)
                                                     .withStringValue("500"));
 
+        messageAttributes.put(myBinary, new MessageAttributeValue()
+                                                    .withDataType(SQSMessagingClientConstants.BINARY)
+                                                    .withStringValue("binarydata"));
+
         com.amazonaws.services.sqs.model.Message sqsMessage = new com.amazonaws.services.sqs.model.Message()
                 .withMessageAttributes(messageAttributes)
                 .withAttributes(systemAttributes)
@@ -383,6 +395,9 @@ public void testSQSMessageAttributeToProperty() throws JMSException {
         Assert.assertEquals(message.getFloatProperty(myNumber), 500f);
         Assert.assertEquals(message.getDoubleProperty(myNumber), 500d);
 
+        Assert.assertTrue(message.propertyExists(myBinary));
+        Assert.assertEquals(message.getObjectProperty(myBinary), "binarydata");
+        Assert.assertEquals(message.getStringProperty(myBinary), "binarydata");
 
         // Validate property names
         Set<String> propertyNamesSet = new HashSet<String>(Arrays.asList(
@@ -396,6 +411,7 @@ public void testSQSMessageAttributeToProperty() throws JMSException {
                 myByte,
                 myString,
                 myNumber,
+                myBinary,
                 JMSX_DELIVERY_COUNT));
 
         Enumeration<String > propertyNames = message.getPropertyNames();
@@ -416,6 +432,7 @@ public void testSQSMessageAttributeToProperty() throws JMSException {
         Assert.assertFalse(message.propertyExists("myByteProperty"));
         Assert.assertFalse(message.propertyExists("myString"));
         Assert.assertFalse(message.propertyExists("myNumber"));
+        Assert.assertFalse(message.propertyExists("myBinary"));
 
         propertyNames = message.getPropertyNames();
         assertFalse(propertyNames.hasMoreElements());