public void contextInitialized()

in aws-blog-kinesis-beanstalk-workers/src/main/java/com/amazonaws/services/kinesis/beanstalk/connector/KinesisWorkerServletInitiator.java [33:56]

22 lines of code
9 McCabe index (conditional complexity)


	public void contextInitialized(ServletContextEvent arg0) {
		String consumerClassName = System.getProperty(WORKER_CLASS_NAME_PARAM);
		String recordProcessorClassName = System
				.getProperty(MANAGED_RECORD_PROCESSOR_CLASS_PARAM);

		if (recordProcessorClassName != null
				&& !recordProcessorClassName.equals("")) {
			String streamName = System.getProperty(STREAM_NAME_PARAM);
			String appName = System.getProperty(APP_NAME_PARAM);

			if (streamName == null || streamName.equals("") || appName == null
					|| appName.equals("")) {
				LOG.error(String
						.format("Unable to use Managed Consumer without parameters %s and %s",
								STREAM_NAME_PARAM, APP_NAME_PARAM));
			} else {
				runManagedWorker(streamName, appName, recordProcessorClassName);
			}
		} else if (consumerClassName != null && !consumerClassName.equals("")) {
			runCustomWorker(consumerClassName);
		} else {
			LOG.warn("No Kinesis Worker Class or IRecordProcessor Class Configured. Environment is ready for configuration using Elastic Beanstalk Properties");
		}
	}