Added new cyclic example query. Added streamId info to tuple to identify origin. Added timeout parameter to inputadapter.pull to avoid the problem of a slow inputadapter in the case of the simpleprocessing engine