Implemented message streaming so we don't have to poll the messages constantly