add hello example

Author: scmacdon

.doc_gen/metadata/scheduler_metadata.yaml

@@ -4,6 +4,14 @@ scheduler_hello:
   synopsis: get started using &EVS;.
   category: Hello
   languages:
+    Java:
+      versions:
+        - sdk_version: 2
+          github: javav2/example_code/eventbridgescheduler
+          excerpts:
+            - description:
+              snippet_tags:
+                - scheduler.javav2.hello.main
     .NET:
       versions:
         - sdk_version: 3

javav2/example_code/eventbridgescheduler/src/main/java/com/example/eventbrideschedule/HelloScheduler.java

@@ -1,4 +1,54 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
 package com.example.eventbrideschedule;
 
+// snippet-start:[scheduler.javav2.hello.main]
+import software.amazon.awssdk.services.scheduler.SchedulerAsyncClient;
+import software.amazon.awssdk.services.scheduler.model.ListSchedulesRequest;
+import software.amazon.awssdk.services.scheduler.model.ScheduleSummary;
+import software.amazon.awssdk.services.scheduler.paginators.ListSchedulesPublisher;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+
 public class HelloScheduler {
+
+    public static void main(String [] args) {
+        listSchedulesAsync();
+    }
+
+    /**
+     * Lists all the schedules available.
+     * <p>
+     * This method uses the {@link SchedulerAsyncClient} to make an asynchronous request to
+     * list all the schedules available. The method uses the {@link ListSchedulesPublisher}
+     * to fetch the schedules in a paginated manner, and then processes the responses
+     * asynchronously.
+     */
+    public static void listSchedulesAsync() {
+        SchedulerAsyncClient schedulerAsyncClient = SchedulerAsyncClient.create();
+
+        // Build the request to list schedules
+        ListSchedulesRequest listSchedulesRequest = ListSchedulesRequest.builder().build();
+
+        // Use the paginator to fetch all schedules asynchronously.
+        ListSchedulesPublisher paginator = schedulerAsyncClient.listSchedulesPaginator(listSchedulesRequest);
+        List<ScheduleSummary> results = new ArrayList<>();
+
+        // Subscribe to the paginator to process the response asynchronously
+        CompletableFuture<Void> future = paginator.subscribe(response -> {
+            response.schedules().forEach(schedule -> {
+                results.add(schedule);
+                System.out.printf("Schedule: %s%n", schedule.name());
+            });
+        });
+
+        // Wait for the asynchronous operation to complete.
+        future.join();
+
+        // After all schedules are fetched, print the total count.
+        System.out.printf("Total of %d schedule(s) available.%n", results.size());
+    }
 }
+// snippet-end:[scheduler.javav2.hello.main]

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

@@ -4,6 +4,7 @@
 package com.example.eventbridgeschedule.scenario;
 
 // snippet-start:[scheduler.javav2.actions.main]
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import software.amazon.awssdk.core.client.config.ClientOverrideConfiguration;
@@ -18,13 +19,15 @@
 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.DeleteScheduleResponse;
 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;
 import java.time.Duration;
+import java.util.concurrent.CompletionException;
 
 public class EventbridgeSchedulerActions {
 
@@ -63,6 +66,7 @@ public static SchedulerAsyncClient getAsyncClient() {
     }
 
     // snippet-start:[scheduler.javav2.create.schedule.group.main]
+
     /**
      * Creates a new schedule group.
      *
@@ -78,8 +82,7 @@ public CompletableFuture<CreateScheduleGroupResponse> createScheduleGroup(String
         CompletableFuture<CreateScheduleGroupResponse> futureResponse = getAsyncClient().createScheduleGroup(request);
         futureResponse.whenComplete((response, ex) -> {
             if (ex != null) {
-                // Throw an exception if something went wrong
-                throw new RuntimeException("Failed to create schedule group: " + name, ex);
+                throw new CompletionException("Failed to create schedule group: " + name, ex);
             } else if (response == null) {
                 throw new RuntimeException("Failed to create schedule group: response was null");
             } else {
@@ -114,11 +117,9 @@ public CompletableFuture<Boolean> createScheduleAsync(
         boolean deleteAfterCompletion,
         boolean useFlexibleTimeWindow) {
 
-        // Define the time windows.
         int hoursToRun = 1;
         int flexibleTimeWindowMinutes = 10;
 
-        // Build the Target for the Schedule.
         Target target = Target.builder()
             .arn(targetArn)
             .roleArn(roleArn)
@@ -152,12 +153,12 @@ public CompletableFuture<Boolean> createScheduleAsync(
 
         return getAsyncClient().createSchedule(request)
             .thenApply(response -> {
-                logger.info("Successfully created schedule '" + name + "' in schedule group '" + scheduleGroupName + "': " + response.scheduleArn());
+                logger.info("Successfully created schedule {} in schedule group {}, The ARN is {} ", name, scheduleGroupName, response.scheduleArn());
                 return true;
             })
             .whenComplete((result, ex) -> {
                 if (ex != null) {
-                    throw new RuntimeException("Error creating schedule: " + ex.getMessage(), ex);
+                    throw new CompletionException("Error creating schedule: " + ex.getMessage(), ex);
                 }
             });
     }
@@ -169,54 +170,51 @@ public CompletableFuture<Boolean> createScheduleAsync(
      *
      * @param name the name of the schedule group to delete
      * @return a {@link CompletableFuture} that completes when the schedule group has been deleted
-     * @throws RuntimeException if an error occurs while deleting the schedule group
+     * @throws CompletionException if an error occurs while deleting the schedule group
      */
     public CompletableFuture<Void> deleteScheduleGroupAsync(String name) {
-        try {
-            DeleteScheduleGroupRequest request = DeleteScheduleGroupRequest.builder()
-                .name(name)
-                .build();
+        DeleteScheduleGroupRequest request = DeleteScheduleGroupRequest.builder()
+            .name(name)
+            .build();
 
-            return getAsyncClient().deleteScheduleGroup(request)
-                .thenRun(() -> {
-                    logger.info("Successfully deleted schedule group {}", name);
-                })
-                .whenComplete((result, ex) -> {
-                    if (ex != null) {
-                        throw new RuntimeException("Error deleting schedule group: " + ex.getMessage(), ex);
-                    }
-                });
-
-        } catch (Exception ex) {
-            throw new RuntimeException("Unexpected error occurred: " + ex.getMessage(), ex);
-        }
+        return getAsyncClient().deleteScheduleGroup(request)
+            .thenRun(() -> {
+                logger.info("Successfully deleted schedule group {}", name);
+            })
+            .whenComplete((result, ex) -> {
+                if (ex != null) {
+                    throw new CompletionException("Error deleting schedule group: " + ex.getMessage(), ex);
+                }
+            });
     }
     // snippet-end:[scheduler.javav2.delete.schedule.group.main]
 
     // snippet-start:[scheduler.javav2.delete.schedule.main]
+    /**
+     * Deletes a schedule with the specified name and group name.
+     *
+     * @param name      the name of the schedule to be deleted
+     * @param groupName the group name of the schedule to be deleted
+     * @return a {@link CompletableFuture} that, when completed, indicates whether the schedule was successfully deleted
+     * @throws CompletionException if an error occurs while deleting the schedule, except for the case where the schedule is not found
+     */
     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());
+        DeleteScheduleRequest request = DeleteScheduleRequest.builder()
+            .name(name)
+            .groupName(groupName)
+            .build();
+
+        CompletableFuture<DeleteScheduleResponse> response = getAsyncClient().deleteSchedule(request);
+        return response.handle((result, ex) -> {
+            if (ex != null) {
+                if (ex instanceof ResourceNotFoundException) {
+                    throw new CompletionException("Resource not found while deleting schedule with ID: " + name, ex);
+                } else {
+                    throw new CompletionException("Failed to delete schedule.", ex);
+                }
             }
+            logger.info("Successfully deleted schedule with name {}.", name);
+            return true;
         });
     }
     // snippet-end:[scheduler.javav2.delete.schedule.main]