a naive patch to set JMSTimestamp, see #20

Author: bat-cha

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

@@ -17,6 +17,7 @@
 import java.util.ArrayDeque;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 
 import javax.jms.JMSException;
 import javax.jms.MessageListener;
@@ -325,8 +326,19 @@ protected javax.jms.Message convertToJMSMessage(Message message) throws JMSExcep
             }
         }
         jmsMessage.setJMSDestination(sqsDestination);
-        return jmsMessage;
-    }
+        jmsMessage.setJMSTimestamp(getJMSTimestamp(message));
+		return jmsMessage;
+	}
+
+	private long getJMSTimestamp(Message message) {
+		Map<String, String> systemAttributes = message.getAttributes();
+		String timestamp = systemAttributes.get(SQSMessagingClientConstants.SENT_TIMESTAMP);
+		if (timestamp != null) {
+			return Long.parseLong(timestamp);
+		} else {
+			return 0L;
+		}
+	}
 
     protected void nackQueueMessages() {
         // Also nack messages already in the messageQueue

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

@@ -61,6 +61,8 @@ public class SQSMessagingClientConstants {
     public static final String JMSX_GROUP_SEC = "JMSXGroupSeq";
 
     public static final String APPROXIMATE_RECEIVE_COUNT = "ApproximateReceiveCount";
+    
+    public static final String SENT_TIMESTAMP = "SentTimestamp";
 
     static final String APPENDED_USER_AGENT_HEADER_VERSION;
     static {
@@ -72,3 +74,4 @@ public class SQSMessagingClientConstants {
         }
     }
 }
+

src/test/java/com/amazon/sqs/javamessaging/SQSMessageConsumerPrefetchTest.java

@@ -44,6 +44,8 @@
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
+
+import org.joda.time.DateTime;
 import org.junit.Before;
 import org.junit.Test;
 
@@ -1018,6 +1020,8 @@ public void testConvertToJMSMessageTextTypeAttribute() throws JMSException, IOEx
 
         Map<String, String> mapAttributes = new HashMap<String, String>();
         mapAttributes.put(SQSMessagingClientConstants.APPROXIMATE_RECEIVE_COUNT, "1");
+        Long now = DateTime.now().getMillis();
+		mapAttributes.put(SQSMessagingClientConstants.SENT_TIMESTAMP, now.toString());
 
         com.amazonaws.services.sqs.model.Message message = mock(com.amazonaws.services.sqs.model.Message.class);
         // Return message attributes with message type 'TEXT'
@@ -1035,6 +1039,7 @@ public void testConvertToJMSMessageTextTypeAttribute() throws JMSException, IOEx
          */
         assertTrue(jsmMessage instanceof SQSTextMessage);
         assertEquals(message.getBody(), "MessageBody");
+        assertEquals(jsmMessage.getJMSTimestamp(), now.longValue());
     }
 
     /**