@ -64,7 +64,7 @@ public class PullAlreadyReadMessageTask {
Thread.sleep(200);
}finally {
// 下一次循环
if(executorService.isShutdown()){
if(!executorService.isShutdown()){
executorService.submit(this);
}