message-driven a-synchronized big data analysis engine