public StreamScaler()

in src/main/java/com/amazonaws/services/kinesis/scaling/StreamScaler.java [67:85]

• 13 lines of code
• 3 McCabe index (conditional complexity)

	public StreamScaler(Region region) throws Exception {
		pctFormat.setMaximumFractionDigits(1);
		
		// use the default provider chain plus support for classpath
		// properties files
		KinesisClientBuilder builder = KinesisClient.builder()
				.credentialsProvider(DefaultCredentialsProvider.builder().build()).region(region);

		String kinesisEndpoint = System.getProperty("kinesisEndpoint");
		if (kinesisEndpoint != null) {
			builder.endpointOverride(new URI(kinesisEndpoint));
		}

		this.kinesisClient = builder.build();

		if (kinesisClient.serviceName() == null) {
			throw new Exception("Unable to reach Kinesis Service");
		}
	}