 				process.exit(1)
 			else if streamStatus is "ACTIVE"
 				console.log "KinesisProducer : stream [#{stream}] is active, initiating put"
-				do initiatePuts
+				do initiatePut
 			else
 				console.log "KinesisProducer : Waiting for stream [#{stream}]"
-				wordProducer.waitForStream stream, initiatePuts
+				wordProducer.waitForStream stream, initiatePut
 		return
 else
 	console.error """

				if err?
					console.log "KinesisProducer : Error creating stream [#{stream}]", err
				else
					do initiatePuts
				return
		if status?
			streamStatus = status.StreamDescription.StreamStatus

	if words.indexOf(',')
		words = words.split(',')
	wordProducer.getStreamStatus stream, (err, status) ->
		initiatePut = ->
			if period?
				wordProducer.putWordsInStreamPeriodically stream, words, period, ->
			else
