+ Added a push based consumer wrapper