initial ver. of Lifestreams bolt that support receiving multiple streams
implement SNAPSHOT command that asks bolts of a sub-topology to process
the latest data.