consistent interface for bolts and streams: implementations use an object and a factory
handle empty messages in consume
remove extraneous imports from test-streams-*
interestStorageBolt