Skip to content

Commit 5c8c3d1

Browse files
authored
Upgrade path (#57)
* Allow to receive MessageS3Pointer and PayloadS3Pointer for compatibility with 1.x
1 parent df0c625 commit 5c8c3d1

3 files changed

Lines changed: 4 additions & 2 deletions

File tree

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ For more information on using the amazon-sqs-java-extended-client-lib, see our g
2424
<dependency>
2525
<groupId>com.amazonaws</groupId>
2626
<artifactId>amazon-sqs-java-extended-client-lib</artifactId>
27-
<version>1.0.2</version>
27+
<version>1.0.3</version>
2828
<type>jar</type>
2929
</dependency>
3030
```

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
<groupId>com.amazonaws</groupId>
88
<artifactId>amazon-sqs-java-extended-client-lib</artifactId>
9-
<version>1.0.2</version>
9+
<version>1.0.3</version>
1010
<packaging>jar</packaging>
1111
<name>Amazon SQS Extended Client Library for Java</name>
1212
<description>An extension to the Amazon SQS client that enables sending and receiving messages up to 2GB via Amazon S3.

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -359,6 +359,8 @@ public ReceiveMessageResult receiveMessage(ReceiveMessageRequest receiveMessageR
359359
if (largePayloadAttributeValue != null) {
360360
String messageBody = message.getBody();
361361

362+
messageBody = messageBody.replace("software.amazon.payloadoffloading.PayloadS3Pointer", "com.amazon.sqs.javamessaging.MessageS3Pointer");
363+
362364
// read the S3 pointer from the message body JSON string.
363365
MessageS3Pointer s3Pointer = readMessageS3PointerFromJSON(messageBody);
364366

0 commit comments

Comments
 (0)