Added CRaC to Powertools Large Messages module and modified protobuf version examples

Author: David-DAM

examples/powertools-examples-kafka/src/main/java/org/demo/kafka/protobuf/ProtobufProduct.java

@@ -14,11 +14,13 @@
   -->
 
 <project xmlns="http://maven.apache.org/POM/4.0.0"
-    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
 
-    <description>A suite of utilities for AWS Lambda Functions that makes handling large messages in SQS and SNS easier.</description>
+    <description>A suite of utilities for AWS Lambda Functions that makes handling large messages in SQS and SNS
+        easier.
+    </description>
 
     <parent>
         <groupId>software.amazon.lambda</groupId>
@@ -87,6 +89,10 @@
             <artifactId>url-connection-client</artifactId>
             <version>${aws.sdk.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.crac</groupId>
+            <artifactId>crac</artifactId>
+        </dependency>
 
         <!-- Test dependencies -->
         <dependency>
@@ -141,6 +147,27 @@
         </dependency>
     </dependencies>
 
+    <profiles>
+        <profile>
+            <id>generate-classesloaded-file</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-surefire-plugin</artifactId>
+                        <configuration>
+                            <argLine>
+                                -Xlog:class+load=info:classesloaded.txt
+                                --add-opens java.base/java.util=ALL-UNNAMED
+                                --add-opens java.base/java.lang=ALL-UNNAMED
+                            </argLine>
+                        </configuration>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
+
     <build>
         <plugins>
             <plugin>

examples/powertools-examples-kafka/src/main/java/org/demo/kafka/protobuf/ProtobufProductOrBuilder.java

@@ -16,15 +16,20 @@
 
 import static software.amazon.lambda.powertools.common.internal.LambdaConstants.AWS_REGION_ENV;
 
+import org.crac.Context;
+import org.crac.Core;
+import org.crac.Resource;
 import software.amazon.awssdk.http.urlconnection.UrlConnectionHttpClient;
 import software.amazon.awssdk.regions.Region;
 import software.amazon.awssdk.services.s3.S3Client;
 import software.amazon.awssdk.services.s3.S3ClientBuilder;
 
 /**
- * Singleton instance for Large Message Config. We need this to provide a way to customize the S3 client configuration used by the annotation.
+ * Singleton instance for Large Message Config. We need this to provide a way to customize the S3 client
+ * configuration used by the annotation.
  * <br/>
- * Optional: Use it in your Lambda constructor to pass a custom {@link S3Client} to the {@link software.amazon.lambda.powertools.largemessages.internal.LargeMessageProcessor}
+ * Optional: Use it in your Lambda constructor to pass a custom {@link S3Client} to the
+ * {@link software.amazon.lambda.powertools.largemessages.internal.LargeMessageProcessor}
  * <br/>
  * If you don't use this, a default S3Client will be created.
  * <pre>
@@ -33,12 +38,13 @@
  * }
  * </pre>
  */
-public class LargeMessageConfig {
+public class LargeMessageConfig implements Resource {
 
     private static final LargeMessageConfig INSTANCE = new LargeMessageConfig();
     private S3Client s3Client;
 
     private LargeMessageConfig() {
+        Core.getGlobalContext().register(this);
     }
 
     /**
@@ -80,4 +86,14 @@ public S3Client getS3Client() {
         }
         return this.s3Client;
     }
+
+    @Override
+    public void beforeCheckpoint(Context<? extends Resource> context) throws Exception {
+        getS3Client();
+    }
+
+    @Override
+    public void afterRestore(Context<? extends Resource> context) throws Exception {
+        // No action needed after restore
+    }
 }

examples/powertools-examples-kafka/src/main/java/org/demo/kafka/protobuf/ProtobufProductOuterClass.java

@@ -17,23 +17,30 @@
 import java.util.Optional;
 import java.util.function.Function;
 
+import org.crac.Context;
+import org.crac.Core;
+import org.crac.Resource;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import software.amazon.lambda.powertools.common.internal.ClassPreLoader;
 import software.amazon.lambda.powertools.largemessages.internal.LargeMessageProcessor;
 import software.amazon.lambda.powertools.largemessages.internal.LargeMessageProcessorFactory;
 
 /**
  * Functional API for processing large messages without AspectJ.
  * <p>
  * Use this class to handle large messages (> 1 MB) from SQS or SNS.
- * When large messages are sent to an SQS Queue or SNS Topic, they are offloaded to S3 and only a reference is passed in the message/record.
+ * When large messages are sent to an SQS Queue or SNS Topic, they are offloaded to S3 and only a reference is passed
+ * in the message/record.
  * <p>
  * {@code LargeMessages} automatically retrieves and optionally deletes messages
- * which have been offloaded to S3 using the {@code amazon-sqs-java-extended-client-lib} or {@code amazon-sns-java-extended-client-lib}
+ * which have been offloaded to S3 using the {@code amazon-sqs-java-extended-client-lib} or {@code amazon-sns-java
+ * -extended-client-lib}
  * client libraries.
  * <p>
- * This version is compatible with version 1.1.0+ and 2.0.0+ of {@code amazon-sqs-java-extended-client-lib} / {@code amazon-sns-java-extended-client-lib}.
+ * This version is compatible with version 1.1.0+ and 2.0.0+ of {@code amazon-sqs-java-extended-client-lib} / {@code
+ * amazon-sns-java-extended-client-lib}.
  * <p>
  * <u>SQS Example</u>:
  * <pre>
@@ -88,12 +95,16 @@
  *
  * @see LargeMessage
  */
-public final class LargeMessages {
+public final class LargeMessages implements Resource {
 
     private static final Logger LOG = LoggerFactory.getLogger(LargeMessages.class);
 
-    private LargeMessages() {
-        // Utility class
+    // Dummy instance to register LargeMessages with CRaC
+    private static final LargeMessages INSTANCE = new LargeMessages();
+
+    // Static block to ensure CRaC registration happens at class loading time
+    static {
+        Core.getGlobalContext().register(INSTANCE);
     }
 
     /**
@@ -108,10 +119,10 @@ private LargeMessages() {
      * String returnValueOfFunction = LargeMessages.processLargeMessage(sqsMessage, processedMsg -&gt; processOrder(processedMsg, orderId, amount));
      * </pre>
      *
-     * @param message the message to process (SQSMessage or SNSRecord)
+     * @param message  the message to process (SQSMessage or SNSRecord)
      * @param function the function to execute with the processed message
-     * @param <T> the message type
-     * @param <R> the return type of the function
+     * @param <T>      the message type
+     * @param <R>      the return type of the function
      * @return the result of the function execution
      */
     public static <T, R> R processLargeMessage(T message, Function<T, R> function) {
@@ -127,11 +138,11 @@ public static <T, R> R processLargeMessage(T message, Function<T, R> function) {
      * String returnValueOfFunction = LargeMessages.processLargeMessage(sqsMessage, processedMsg -&gt; processOrder(processedMsg, orderId, amount), false);
      * </pre>
      *
-     * @param message the message to process (SQSMessage or SNSRecord)
-     * @param function the function to execute with the processed message
+     * @param message        the message to process (SQSMessage or SNSRecord)
+     * @param function       the function to execute with the processed message
      * @param deleteS3Object whether to delete the S3 object after processing
-     * @param <T> the message type
-     * @param <R> the return type of the function
+     * @param <T>            the message type
+     * @param <R>            the return type of the function
      * @return the result of the function execution
      */
     public static <T, R> R processLargeMessage(T message, Function<T, R> function, boolean deleteS3Object) {
@@ -153,4 +164,14 @@ public static <T, R> R processLargeMessage(T message, Function<T, R> function, b
             throw new LargeMessageProcessingException("Failed to process large message", t);
         }
     }
+
+    @Override
+    public void beforeCheckpoint(Context<? extends Resource> context) throws Exception {
+        ClassPreLoader.preloadClasses();
+    }
+
+    @Override
+    public void afterRestore(Context<? extends Resource> context) throws Exception {
+        // No action needed after restore
+    }
 }