ensure to fix duplicate consume message bug.