public void put()

in lambda/src/main/java/cn/amazon/aws/rp/spapi/eventbridge/OrderReceivedEventGenerator.java [111:147]
33 lines of code
5 McCabe index (conditional complexity)

    public void put() {
        logger.debug("received put event.");
        PutEventsRequestEntry requestEntry = new PutEventsRequestEntry()
                .withTime(new Date())
                .withEventBusName(BUS_NAME)
                .withSource(SOURCE_NAME)
                .withDetailType(DETAIL_TYPE_NEW_ORDER)
                .withDetail("{ \"key1\": \"value1\", \"key2\": \"value2\" }");

        List<PutEventsRequestEntry> putEventsRequestEntryList = new ArrayList<>();
        for (int i = 0; i < 3; i++) {
            putEventsRequestEntryList.add(requestEntry);
        }

        PutEventsRequest putEventsRequest = new PutEventsRequest();
        putEventsRequest.withEntries(putEventsRequestEntryList);
        PutEventsResult putEventsResult = eventBridgeClient.putEvents(putEventsRequest);

        while (putEventsResult.getFailedEntryCount() > 0) {
            logger.error("failed and retry.");
            final List<PutEventsRequestEntry> failedEntriesList = new ArrayList<>();
            final List<PutEventsResultEntry> PutEventsResultEntryList = putEventsResult.getEntries();
            for (int i = 0; i < PutEventsResultEntryList.size(); i++) {
                final PutEventsRequestEntry putEventsRequestEntry = putEventsRequestEntryList.get(i);
                final PutEventsResultEntry putEventsResultEntry = PutEventsResultEntryList.get(i);
                if (putEventsResultEntry.getErrorCode() != null) {
                    failedEntriesList.add(putEventsRequestEntry);
                }
            }

            putEventsRequestEntryList = failedEntriesList;
            putEventsRequest.setEntries(putEventsRequestEntryList);
            putEventsResult = eventBridgeClient.putEvents(putEventsRequest);
            logger.error("retried.");
        }
        logger.info("exist");
    }