public String handleRequest()

in src/main/java/com/amazonaws/kvstranscribestreaming/handler/KVSTranscribeStreamingHandler.java [98:123]


    public String handleRequest(String eventBody) {
        try {

            Map<String, Object> eventBodyMap = objectMapper.readValue(eventBody, Map.class);
            Map<String, String> eventDetail = (Map) eventBodyMap.get("detail");

            String streamingStatus = eventDetail.get("streamingStatus");
            String transactionId = eventDetail.get("transactionId");
            this.transactionId = transactionId;
            logger.info("Received STARTED event");

            if (StreamingStatus.STARTED.name().equals(streamingStatus)) {
                final StreamingStatusStartedDetail streamingStatusStartedDetail = objectMapper.convertValue(eventDetail,
                        StreamingStatusStartedDetail.class);

                logger.info("[{}] Streaming status {} , EventDetail: {}", transactionId, streamingStatus, streamingStatusStartedDetail);
                startKVSToTranscribeStreaming(streamingStatusStartedDetail);
            }

            logger.info("[{}] Finished processing request", this.transactionId);
        } catch (Exception e) {
            logger.error("[{}] KVS to Transcribe Streaming failed with: ", this.transactionId, e);
            return "{ \"result\": \"Failed\" }";
        }
        return "{ \"result\": \"Success\" }";
    }