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 cfb4644..6dd0238 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(false)
+				_ = res.Reject(true)
 			} 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 246794f..8d15faf 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(false)
+				_ = res.Reject(true)
 			} 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 2f22107..4e7c8de 100644
--- a/consume/dou_shen_user_register_for_official_consume.go
+++ b/consume/dou_shen_user_register_for_official_consume.go
@@ -40,7 +40,7 @@ func DouShenUserRegisterConsumeForOfficial(queue md.MqQueue) {
 			err = handleDouShenUserRegisterConsumeForOfficial(res.Body)
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
-				_ = res.Reject(false)
+				_ = res.Reject(true)
 			} 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 863d2db..b9f7864 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(false)
+				_ = res.Reject(true)
 			} else {
 				_ = res.Ack(true)
 			}