private static void loadProperties()

in aws-blog-kinesis-data-visualization/KinesisApplication/src/main/java/com/amazonaws/kinesis/dataviz/kinesisclient/KinesisApplication.java [144:193]

42 lines of code
8 McCabe index (conditional complexity)


   private static void loadProperties(String propertiesFile) throws IOException {
       FileInputStream inputStream = new FileInputStream(propertiesFile);
       Properties properties = new Properties();
       try {
           properties.load(inputStream);
       } finally {
           inputStream.close();
       }

       String appNameOverride = properties.getProperty(ConfigKeys.APPLICATION_NAME_KEY);
       if (appNameOverride != null) {
           applicationName = appNameOverride;
       }
       LOG.info("Using application name " + applicationName);

       String streamNameOverride = properties.getProperty(ConfigKeys.STREAM_NAME_KEY);
       if (streamNameOverride != null) {
           streamName = streamNameOverride;
       }
       LOG.info("Using stream name " + streamName);

       String kinesisEndpointOverride = properties.getProperty(ConfigKeys.KINESIS_ENDPOINT_KEY);
       if (kinesisEndpointOverride != null) {
           kinesisEndpoint = kinesisEndpointOverride;
       }
       LOG.info("Using Kinesis endpoint " + kinesisEndpoint);
       
       String initialPositionOverride = properties.getProperty(ConfigKeys.INITIAL_POSITION_IN_STREAM_KEY);
       if (initialPositionOverride != null) {
            initialPositionInStream = InitialPositionInStream.valueOf(initialPositionOverride);
       }
       LOG.info("Using initial position " + initialPositionInStream.toString() + " (if a checkpoint is not found).");
       
       String redisEndpointOverride = properties.getProperty(ConfigKeys.REDIS_ENDPOINT);
       if (redisEndpointOverride != null) {
           redisEndpoint = redisEndpointOverride;
       }
       LOG.info("Using Redis endpoint " + redisEndpoint);
       
       String redisPortOverride = properties.getProperty(ConfigKeys.REDIS_PORT);
       if (redisPortOverride != null) {
       	try {
       		redisPort = Integer.parseInt(redisPortOverride);
       	} catch(Exception e) {
       		
       	}
       }
       LOG.info("Using Redis port " + redisPort);
        
   }