in sources/coffeeshop/infrastructure/src/main/java/solid/humank/coffeeshop/infra/adapters/CloudWatchEventAdapter.java [42:71]
private PublishResult putEvent(String eventContent) {
//add a comment for test AWS codeGuru
CloudWatchEventsClient cwe = CloudWatchEventsClient.builder().httpClientBuilder(UrlConnectionHttpClient.builder())
.build();
try {
Properties cweProp = getCWEParameters();
PutEventsRequestEntry request_entry = PutEventsRequestEntry.builder()
.detail(eventContent)
.detailType("customevent")
.resources(SSMUtil.getParameter(cweProp.getProperty("ORDER_CREATED_RESOURCE_ARN")))
.source(SSMUtil.getParameter(cweProp.getProperty("ORDER_CREATED_EVENT_SOURCE")))
.build();
PutEventsRequest request = PutEventsRequest.builder()
.entries(request_entry).build();
PutEventsResponse response = cwe.putEvents(request);
logger.info(response.toString());
return new PublishResult(response.toString());
} catch (FileNotFoundException e) {
e.printStackTrace();
}
return new PublishResult("AWS Cloud Watch Events configuration is not correct. The event is not published:" + eventContent);
}