diff --git a/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedAsyncClient.java b/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedAsyncClient.java index 02404a2..e396621 100644 --- a/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedAsyncClient.java +++ b/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedAsyncClient.java @@ -490,7 +490,7 @@ private CompletableFuture storeMessageInS3(SendMessageReques clientConfiguration.usesLegacyReservedAttributeName())); // Store the message content in S3. - return payloadStore.storeOriginalPayload(messageContentStr) + return storeOriginalPayload(messageContentStr) .thenApply(largeMessagePointer -> { sendMessageRequestBuilder.messageBody(largeMessagePointer); return sendMessageRequestBuilder.build();