Issue 55 (#56)

* Fix issue#55 when reading MessageS3Pointer
awslabs · Oct 6, 2020 · 2568cec · 2568cec
1 parent 7a79ecf
commit 2568cec
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedClient.java b/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedClient.java
@@ -355,6 +355,7 @@ public ReceiveMessageResult receiveMessage(ReceiveMessageRequest receiveMessageR
             Optional<String> largePayloadAttributeName = getReservedAttributeNameIfPresent(message.getMessageAttributes());
             if (largePayloadAttributeName.isPresent()) {
                 String largeMessagePointer = message.getBody();
+                largeMessagePointer = largeMessagePointer.replace("com.amazon.sqs.javamessaging.MessageS3Pointer", "software.amazon.payloadoffloading.PayloadS3Pointer");
 
                 message.setBody(payloadStore.getOriginalPayload(largeMessagePointer));