Add support for s3 send and receive using stream message

pom.xml

@@ -57,7 +57,7 @@
     <dependency>
       <groupId>software.amazon.payloadoffloading</groupId>
       <artifactId>payloadoffloading-common</artifactId>
-      <version>2.2.0</version>
+      <version>2.3.0</version>
     </dependency>
 
     <!-- https://mvnrepository.com/artifact/commons-logging/commons-logging -->

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

@@ -212,4 +212,10 @@ public ExtendedAsyncClientConfiguration withServerSideEncryption(ServerSideEncry
         this.setServerSideEncryptionStrategy(serverSideEncryption);
         return this;
     }
+
+    @Override
+    public ExtendedAsyncClientConfiguration withStreamUploadEnabled(boolean enabled) {
+        setStreamUploadEnabled(enabled);
+        return this;
+    }
 }

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

@@ -232,6 +232,26 @@ public ExtendedClientConfiguration withServerSideEncryption(ServerSideEncryption
         return this;
     }
 
+    /**
+     * Enables or disables stream upload support for large payload storage operations.
+     * @param enabled true to enable stream uploads when threshold exceeded.
+     * @return updated configuration
+     */
+    public ExtendedClientConfiguration withStreamUploadEnabled(boolean enabled) {
+        setStreamUploadEnabled(enabled);
+        return this;
+    }
+
+    public ExtendedClientConfiguration withStreamUploadThreshold(int threshold) {
+        setStreamUploadThreshold(threshold);
+        return this;
+    }
+
+    public ExtendedClientConfiguration withStreamUploadPartSize(int partSize) {
+        setStreamUploadPartSize(partSize);
+        return this;
+    }
+
     /**
      * Enables support for large-payload messages.
      *

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

@@ -0,0 +1,21 @@
+package com.amazon.sqs.javamessaging;
+
+import java.util.List;
+
+/**
+ * Response containing messages with streaming access to large payloads.
+ */
+public class ReceiveStreamMessageResponse {
+    private final List<StreamMessage> streamMessages;
+
+    public ReceiveStreamMessageResponse(List<StreamMessage> streamMessages) {
+        this.streamMessages = streamMessages;
+    }
+
+    /**
+     * @return list of messages with streaming payload access
+     */
+    public List<StreamMessage> streamMessages() {
+        return streamMessages;
+    }
+}

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

@@ -0,0 +1,40 @@
+package com.amazon.sqs.javamessaging;
+
+import software.amazon.awssdk.core.ResponseInputStream;
+import software.amazon.awssdk.services.s3.model.GetObjectResponse;
+import software.amazon.awssdk.services.sqs.model.Message;
+
+/**
+ * Represents a message received from SQS that can provide streaming access to large payloads stored in S3.
+ * Instead of loading the entire payload into memory, this provides access to the payload as a stream.
+ */
+public class StreamMessage {
+    private final Message originalMessage;
+    private final ResponseInputStream<GetObjectResponse> payloadStream;
+
+    public StreamMessage(Message originalMessage, ResponseInputStream<GetObjectResponse> payloadStream) {
+        this.originalMessage = originalMessage;
+        this.payloadStream = payloadStream;
+    }
+
+    /**
+     * @return the original SQS message metadata (messageId, receiptHandle, attributes, etc.)
+     */
+    public Message getMessage() {
+        return originalMessage;
+    }
+
+    /**
+     * @return stream for accessing the message payload, or null if payload is not stored in S3
+     */
+    public ResponseInputStream<GetObjectResponse> getPayloadStream() {
+        return payloadStream;
+    }
+
+    /**
+     * @return true if this message has a streaming payload from S3
+     */
+    public boolean hasStreamPayload() {
+        return payloadStream != null;
+    }
+}