add eventbridge scheduler code and YAML SOS file

Author: scmacdon

.doc_gen/metadata/scheduler_metadata.yaml

@@ -17,6 +17,14 @@ scheduler_hello:
     scheduler: {ListSchedules}
 scheduler_CreateSchedule:
   languages:
+    Java:
+      versions:
+        - sdk_version: 2
+          github: javav2/example_code/eventbridgescheduler
+          excerpts:
+            - description:
+              snippet_tags:
+                - scheduler.javav2.create.schedule.main
     .NET:
       versions:
         - sdk_version: 3
@@ -30,6 +38,14 @@ scheduler_CreateSchedule:
     scheduler: {CreateSchedule}
 scheduler_CreateScheduleGroup:
   languages:
+    Java:
+      versions:
+        - sdk_version: 2
+          github: javav2/example_code/eventbridgescheduler
+          excerpts:
+            - description:
+              snippet_tags:
+                - scheduler.javav2.create.schedule.group.main
     .NET:
       versions:
         - sdk_version: 3
@@ -43,7 +59,15 @@ scheduler_CreateScheduleGroup:
     scheduler: {CreateScheduleGroup}
 scheduler_DeleteSchedule:
   languages:
-    .NET:
+   Java:
+      versions:
+        - sdk_version: 2
+          github: javav2/example_code/eventbridgescheduler
+          excerpts:
+            - description:
+              snippet_tags:
+                - scheduler.javav2.delete.schedule.main
+   .NET:
       versions:
         - sdk_version: 3
           github: dotnetv3/EventBridge Scheduler
@@ -56,6 +80,14 @@ scheduler_DeleteSchedule:
     scheduler: {DeleteSchedule}
 scheduler_DeleteScheduleGroup:
   languages:
+    Java:
+      versions:
+        - sdk_version: 2
+          github: javav2/example_code/eventbridgescheduler
+          excerpts:
+            - description:
+              snippet_tags:
+                - scheduler.javav2.delete.schedule.group.main
     .NET:
       versions:
         - sdk_version: 3

javav2/example_code/eventbridgescheduler/src/main/java/com/example/eventbridgeschedule/scenario/EventbridgeSchedulerActions.java

@@ -17,8 +17,10 @@
 import software.amazon.awssdk.services.scheduler.model.CreateScheduleGroupResponse;
 import software.amazon.awssdk.services.scheduler.model.CreateScheduleRequest;
 import software.amazon.awssdk.services.scheduler.model.DeleteScheduleGroupRequest;
+import software.amazon.awssdk.services.scheduler.model.DeleteScheduleRequest;
 import software.amazon.awssdk.services.scheduler.model.FlexibleTimeWindow;
 import software.amazon.awssdk.services.scheduler.model.FlexibleTimeWindowMode;
+import software.amazon.awssdk.services.scheduler.model.ResourceNotFoundException;
 import software.amazon.awssdk.services.scheduler.model.Target;
 import java.time.Instant;
 import java.util.concurrent.CompletableFuture;
@@ -190,5 +192,33 @@ public CompletableFuture<Void> deleteScheduleGroupAsync(String name) {
         }
     }
     // snippet-end:[scheduler.javav2.delete.schedule.group.main]
+
+    // snippet-start:[scheduler.javav2.delete.schedule.main]
+    public CompletableFuture<Boolean> deleteScheduleAsync(String name, String groupName) {
+        return CompletableFuture.supplyAsync(() -> {
+            try {
+                DeleteScheduleRequest request = DeleteScheduleRequest.builder()
+                    .name(name)
+                    .groupName(groupName)
+                    .build();
+
+                getAsyncClient().deleteSchedule(request).get();
+                logger.info(String.format("Successfully deleted schedule with name '%s'.", name));
+                return true;
+            } catch (ResourceNotFoundException ex) {
+                logger.info(String.format("Failed to delete schedule with ID '%s' because the resource was not found: %s", name, ex.getMessage()));
+                return true;
+            } catch (Exception ex) {
+                logger.info(String.format("An error occurred while deleting schedule with ID '%s': %s", name, ex.getMessage()));
+                return false;
+            }
+        }).whenComplete((result, throwable) -> {
+            if (throwable != null) {
+                // Handle any exceptions that occurred during the operation
+                logger.info("Error deleting schedule: " + throwable.getMessage());
+            }
+        });
+    }
+    // snippet-end:[scheduler.javav2.delete.schedule.main]
 }
 // snippet-end:[scheduler.javav2.actions.main]

javav2/example_code/eventbridgescheduler/src/main/java/com/example/eventbridgeschedule/scenario/EventbridgeSchedulerScenario.java

@@ -48,6 +48,8 @@ public class EventbridgeSchedulerScenario {
     private static String STACK_NAME = "scott-workflow-stack-name11";
     private static final String scheduleGroupName = "scott-schedules-group11";
 
+    private static String recurringScheduleName = "";
+
     private static final EventbridgeSchedulerActions eventbridgeActions = new EventbridgeSchedulerActions();
 
     public static final String DASHES = new String(new char[80]).replace("\0", "-");
@@ -131,6 +133,13 @@ public static void cleanUp() {
         logger.info("First, delete the schedule groups name");
         waitForInputToContinue(scanner);
         eventbridgeActions.deleteScheduleGroupAsync(scheduleGroupName);
+
+        logger.info("Next, delete the schedules");
+        waitForInputToContinue(scanner);
+        eventbridgeActions.deleteScheduleAsync("", recurringScheduleName);
+
+        logger.info("Finally, destroy the CloudFormation stack");
+        waitForInputToContinue(scanner);
         CloudFormationHelper.destroyCloudFormationStack(STACK_NAME);
     }
 
@@ -260,11 +269,12 @@ public static Boolean createOneTimeSchedule() {
      */
     public static Boolean createRecurringSchedule() {
         logger.info("Creating a recurring schedule to send events for one hour...");
-        String scheduleName = promptUserForResourceName("Enter a name for the recurring schedule:");
+        recurringScheduleName = promptUserForResourceName("Enter a name for the recurring schedule:");
 
         // Prompt the user for the schedule rate (in minutes).
         int scheduleRateInMinutes = promptUserForInteger("Enter the desired schedule rate (in minutes): ");
         String scheduleExpression = "rate(" + scheduleRateInMinutes + " minutes)";
+       /*
         try {
             // Call the asynchronous method and wait for it to complete
             eventbridgeActions.createScheduleGroup(scheduleName).join(); // Use join() to block until completion
@@ -274,14 +284,14 @@ public static Boolean createRecurringSchedule() {
             // Handle the exception thrown from the whenComplete block
             logger.info("Error occurred: {} ", e.getMessage());
         }
-
+       */
         return eventbridgeActions.createScheduleAsync(
-            scheduleName,
+            recurringScheduleName,
             scheduleExpression,
             scheduleGroupName,
             snsTopicArn,
             roleArn,
-            "Recurrent event test from schedule " + scheduleName,
+            "Recurrent event test from schedule " + recurringScheduleName,
             true,
             true).join();
     }