Skip to content

Commit 143186d

Browse files
committed
add eventbridge scheduler code and YAML SOS file
1 parent af6be31 commit 143186d

File tree

2 files changed

+15
-13
lines changed

2 files changed

+15
-13
lines changed

.doc_gen/metadata/scheduler_metadata.yaml

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,19 @@ scheduler_ScheduledEventsWorkflow:
111111
- Clean up resources and delete the stack.
112112
category: Scenarios
113113
languages:
114+
Java:
115+
versions:
116+
- sdk_version: 2
117+
github: javav2/example_code/eventbridgescheduler
118+
excerpts:
119+
- description: Run the workflow.
120+
genai: most
121+
snippet_tags:
122+
- scheduler.javav2.scenario.main
123+
- description: Wrapper for service operations.
124+
genai: most
125+
snippet_tags:
126+
- scheduler.javav2.actions.main
114127
.NET:
115128
versions:
116129
- sdk_version: 3

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

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -132,11 +132,11 @@ public static void main(String[] args) {
132132
public static void cleanUp() {
133133
logger.info("First, delete the schedule groups name");
134134
waitForInputToContinue(scanner);
135-
eventbridgeActions.deleteScheduleGroupAsync(scheduleGroupName);
135+
eventbridgeActions.deleteScheduleGroupAsync(scheduleGroupName).join();
136136

137137
logger.info("Next, delete the schedules");
138138
waitForInputToContinue(scanner);
139-
eventbridgeActions.deleteScheduleAsync("", recurringScheduleName);
139+
eventbridgeActions.deleteScheduleAsync(recurringScheduleName, scheduleGroupName).join();
140140

141141
logger.info("Finally, destroy the CloudFormation stack");
142142
waitForInputToContinue(scanner);
@@ -274,17 +274,6 @@ public static Boolean createRecurringSchedule() {
274274
// Prompt the user for the schedule rate (in minutes).
275275
int scheduleRateInMinutes = promptUserForInteger("Enter the desired schedule rate (in minutes): ");
276276
String scheduleExpression = "rate(" + scheduleRateInMinutes + " minutes)";
277-
/*
278-
try {
279-
// Call the asynchronous method and wait for it to complete
280-
eventbridgeActions.createScheduleGroup(scheduleName).join(); // Use join() to block until completion
281-
282-
logger.info("createScheduleGroupAsync completed successfully.");
283-
} catch (RuntimeException e) {
284-
// Handle the exception thrown from the whenComplete block
285-
logger.info("Error occurred: {} ", e.getMessage());
286-
}
287-
*/
288277
return eventbridgeActions.createScheduleAsync(
289278
recurringScheduleName,
290279
scheduleExpression,

0 commit comments

Comments
 (0)