diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java
index a34a8257..e2b81b2e 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java
@@ -4,6 +4,7 @@ import java.util.List;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.util.CollectionUtils;
 
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
 import com.gzzn.omms.msgexchangeapi.msghandler.MsgHandlerDispatcher;
@@ -58,7 +59,11 @@ public class MsgExchangeRunner  implements Runnable{
 			msgHandlerDispatcher.dispatch(cminmsg);
 		}//end for
 		
-		
+		if(!CollectionUtils.isEmpty(lsCminmsgs))
+		{
+			beginId =  lsCminmsgs.get(lsCminmsgs.size()-1).getCminmsgsId();//偏移到最新位置，等待最新的消息
+			redisService.set(RedisKeyConstant.KEY_LASTBEGINID,beginId);
+		}
 		logger.info("本次定时获取新消息完成...");
 	}//end run
 }