A Middleware for Distrubted Data Stream Processing