update

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)
 			}

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)
 			}

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)
 			}

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)
 			}