Storm-styled stream processing in C++, scaled down for a single machine