Skip to content

Commit 2568cec

Browse files
authored
Issue 55 (#56)
* Fix issue#55 when reading MessageS3Pointer
1 parent 7a79ecf commit 2568cec

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -355,6 +355,7 @@ public ReceiveMessageResult receiveMessage(ReceiveMessageRequest receiveMessageR
355355
Optional<String> largePayloadAttributeName = getReservedAttributeNameIfPresent(message.getMessageAttributes());
356356
if (largePayloadAttributeName.isPresent()) {
357357
String largeMessagePointer = message.getBody();
358+
largeMessagePointer = largeMessagePointer.replace("com.amazon.sqs.javamessaging.MessageS3Pointer", "software.amazon.payloadoffloading.PayloadS3Pointer");
358359

359360
message.setBody(payloadStore.getOriginalPayload(largeMessagePointer));
360361

0 commit comments

Comments
 (0)