adding updateStateByKey object lifecycle test
Splitting StreamingContext.queueStream into two methods