complex event stream processing module for mongodb