diff --git a/consume/dou_shen_user_register_for_my_my_fans.go b/consume/dou_shen_user_register_for_my_my_fans.go
index 2b81c21..a0e46f7 100644
--- a/consume/dou_shen_user_register_for_my_my_fans.go
+++ b/consume/dou_shen_user_register_for_my_my_fans.go
@@ -42,7 +42,7 @@ func DouShenUserRegisterConsumeForMyFans(queue md.MqQueue) {
 			err = handleDouShenUserRegisterConsumeForMyFans(res.Body)
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
-				_ = res.Reject(true)
+				_ = res.Reject(false)
 			} else {
 				_ = res.Ack(true)
 			}
diff --git a/consume/dou_shen_user_register_for_my_my_recommender.go b/consume/dou_shen_user_register_for_my_my_recommender.go
index 8d15faf..246794f 100644
--- a/consume/dou_shen_user_register_for_my_my_recommender.go
+++ b/consume/dou_shen_user_register_for_my_my_recommender.go
@@ -38,7 +38,7 @@ func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) {
 			err = handleDouShenUserRegisterConsumeForMyRecommender(res.Body)
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
-				_ = res.Reject(true)
+				_ = res.Reject(false)
 			} else {
 				_ = res.Ack(true)
 			}
diff --git a/consume/dou_shen_user_register_for_official_consume.go b/consume/dou_shen_user_register_for_official_consume.go
index e79e657..50f366b 100644
--- a/consume/dou_shen_user_register_for_official_consume.go
+++ b/consume/dou_shen_user_register_for_official_consume.go
@@ -41,7 +41,7 @@ func DouShenUserRegisterConsumeForOfficial(queue md.MqQueue) {
 			err = handleDouShenUserRegisterConsumeForOfficial(res.Body)
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
-				_ = res.Reject(true)
+				_ = res.Reject(false)
 			} else {
 				_ = res.Ack(true)
 			}
diff --git a/consume/dou_shen_user_register_for_operation_center.go b/consume/dou_shen_user_register_for_operation_center.go
index b9f7864..863d2db 100644
--- a/consume/dou_shen_user_register_for_operation_center.go
+++ b/consume/dou_shen_user_register_for_operation_center.go
@@ -38,7 +38,7 @@ func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) {
 			err = handleDouShenUserRegisterConsumeForOperationCenter(res.Body)
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
-				_ = res.Reject(true)
+				_ = res.Reject(false)
 			} else {
 				_ = res.Ack(true)
 			}