Merge pull request !3 from blue/v_1.1.0
@ -64,7 +64,7 @@ public class PullAlreadyReadMessageTask {
Thread.sleep(200);
}finally {
// 下一次循环
if(executorService.isShutdown()){
if(!executorService.isShutdown()){
executorService.submit(this);
}