src/integrationtests/java/com/aws/iot/integrationtests/edgeconnectorforkvs/videouploader/VideoUploaderIntegrationTest.java [142:167]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private static boolean createKvsStream(AWSCredentials awsCredentials, Region region, String streamName,
                                           int dataRetentionInHours) {
        boolean result = false;

        AmazonKinesisVideo client = AmazonKinesisVideoClient.builder()
                .withRegion(region.toString())
                .withCredentials(new AWSStaticCredentialsProvider(awsCredentials))
                .build();

        try {
            CreateStreamResult stream = client.createStream(
                    new CreateStreamRequest().
                            withStreamName(streamName).
                            withDataRetentionInHours(dataRetentionInHours));
            if (stream.getSdkHttpMetadata().getHttpStatusCode() == 200) {
                log.info("Created KVS stream: " + streamName);
                result = true;
            } else {
                log.error("Unable to create KVS stream");
            }
        } catch (Exception ex) {
            log.error("Unable to create KVS stream");
        }

        return result;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/integrationtests/java/com/aws/iot/integrationtests/edgeconnectorforkvs/HistoricalUploadingIntegrationTest.java [144:169]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private static boolean createKvsStream(AWSCredentials awsCredentials, Region region, String streamName,
                                           int dataRetentionInHours) {
        boolean result = false;

        AmazonKinesisVideo client = AmazonKinesisVideoClient.builder()
                .withRegion(region.toString())
                .withCredentials(new AWSStaticCredentialsProvider(awsCredentials))
                .build();

        try {
            CreateStreamResult stream = client.createStream(
                    new CreateStreamRequest().
                            withStreamName(streamName).
                            withDataRetentionInHours(dataRetentionInHours));
            if (stream.getSdkHttpMetadata().getHttpStatusCode() == 200) {
                log.info("Created KVS stream: " + streamName);
                result = true;
            } else {
                log.error("Unable to create KVS stream");
            }
        } catch (Exception ex) {
            log.error("Unable to create KVS stream");
        }

        return result;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/integrationtests/java/com/aws/iot/integrationtests/edgeconnectorforkvs/LiveUploadingIntegrationTest.java [110:135]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private static boolean createKvsStream(AWSCredentials awsCredentials, Region region, String streamName,
                                           int dataRetentionInHours) {
        boolean result = false;

        AmazonKinesisVideo client = AmazonKinesisVideoClient.builder()
                .withRegion(region.toString())
                .withCredentials(new AWSStaticCredentialsProvider(awsCredentials))
                .build();

        try {
            CreateStreamResult stream = client.createStream(
                    new CreateStreamRequest().
                            withStreamName(streamName).
                            withDataRetentionInHours(dataRetentionInHours));
            if (stream.getSdkHttpMetadata().getHttpStatusCode() == 200) {
                log.info("Created KVS stream: " + streamName);
                result = true;
            } else {
                log.error("Unable to create KVS stream");
            }
        } catch (Exception ex) {
            log.error("Unable to create KVS stream");
        }

        return result;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -