diff --git a/json/save2json.cpp b/json/save2json.cpp
index 5946f6f..b1375e8 100644
--- a/json/save2json.cpp
+++ b/json/save2json.cpp
@@ -2384,7 +2384,7 @@ char* find_mp_name_from_mp_id(const char* mp_id)
 ConsumeStatus myMessageCallbackrtdata(
     const rocketmq::MQMessageExt& msg)
 {
-	if(INITFLAG != 1)return 1;//防止崩溃
+	if(INITFLAG != 1)return rocketmq::RECONSUME_LATER;//防止崩溃
 
 	if (!should_process_after_start(msg)) {
 	    std::cout << "[MQ] skip old message: "
@@ -2479,7 +2479,7 @@ ConsumeStatus myMessageCallbackrtdata(
 ConsumeStatus myMessageCallbackupdate(
 	const rocketmq::MQMessageExt& msg)
 {
-	if(INITFLAG != 1)return 1;//防止崩溃
+	if(INITFLAG != 1)return rocketmq::RECONSUME_LATER;//防止崩溃
 
 	if (!should_process_after_start(msg)) {
 	    std::cout << "[MQ] skip old message: "
@@ -2550,7 +2550,7 @@ ConsumeStatus myMessageCallbackupdate(
 ConsumeStatus myMessageCallbackset(
 	const rocketmq::MQMessageExt& msg)
 {
-	if(INITFLAG != 1)return 1;//防止崩溃
+	if(INITFLAG != 1)return rocketmq::RECONSUME_LATER;//防止崩溃
 
 	if (!should_process_after_start(msg)) {
 	    std::cout << "[MQ] skip old message: "
@@ -2613,7 +2613,7 @@ ConsumeStatus myMessageCallbackset(
 ConsumeStatus myMessageCallbacklog(
 	const rocketmq::MQMessageExt& msg)
 {
-	if(INITFLAG != 1)return 1;//防止崩溃
+	if(INITFLAG != 1)return rocketmq::RECONSUME_LATER;//防止崩溃
 
 	if (!should_process_after_start(msg)) {
 	    std::cout << "[MQ] skip old message: "
@@ -2676,7 +2676,7 @@ ConsumeStatus myMessageCallbacklog(
 ConsumeStatus myMessageCallbackrecall(
 	const rocketmq::MQMessageExt& msg)
 {
-	if(INITFLAG != 1)return 1;//防止崩溃
+	if(INITFLAG != 1)return rocketmq::RECONSUME_LATER;//防止崩溃
 
 	if (!should_process_after_start(msg)) {
 	    std::cout << "[MQ] skip old message: "
@@ -2752,7 +2752,7 @@ ConsumeStatus myMessageCallbackrecall(
 ConsumeStatus myMessageCallbackfile(
 	const rocketmq::MQMessageExt& msg)
 {
-    if (INITFLAG != 1) return 1;
+    if (INITFLAG != 1)return rocketmq::RECONSUME_LATER;
 
 	if (!should_process_after_start(msg)) {
 	    std::cout << "[MQ] skip old message: "
diff --git a/librocketmq.a b/librocketmq.a
index b6e0ea7..fcc0e9c 100644
Binary files a/librocketmq.a and b/librocketmq.a differ
diff --git a/librocketmq.so b/librocketmq.so
index b236177..812e6c4 100644
Binary files a/librocketmq.so and b/librocketmq.so differ