ensure to fix duplicate consume message bug.
ensure to fix duplicate consume message bug.

geffzhang/equeue,Aaron-Liu/equeue,tangxuehua/equeue,tangxuehua/equeue,geffzhang/equeue,tangxuehua/equeue,Aaron-Liu/equeue