countDownLatch.countDown(); 使用方法后移，保证数据被处理后激活线程。注意数据处理异常时的
countDownLatch.countDown()的有效调用
增加 测试案例
#4 增加查询消息日志
#1 开发push consumer，拉消息支持Suspend
#1 开发push consumer，拉消息支持Suspend
Merge https://github.com/alibaba/RocketMQ