Not sure where I am at the moment.
Naming processes for servers.
Naming processes for servers.
passing event manager to bolt server
Spawning process per message.  That process will create and manage the Tuple tree for this stream through the topology.
Setting pid of spout server so module can emit messages to it.
Removing format statement in loop
Stream process module, just starting.
Moved groupings underneath bolts, just like in Storm.
FSM for stream processing.
Added workers property back, perhaps use it for redundency setting