diff --git a/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/client/SnailRetryEndPoint.java b/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/client/SnailRetryEndPoint.java index 3b056b32..17612e46 100644 --- a/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/client/SnailRetryEndPoint.java +++ b/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/client/SnailRetryEndPoint.java @@ -39,7 +39,6 @@ import org.springframework.validation.annotation.Validated; import java.lang.reflect.Method; import java.util.Objects; -import java.util.Set; import static com.aizuda.snailjob.common.core.constant.SystemConstants.HTTP_PATH.*; @@ -141,14 +140,6 @@ public class SnailRetryEndPoint { @Mapping(path = RETRY_CALLBACK, method = RequestMethod.POST) public Result callback(@Valid RetryCallbackDTO callbackDTO) { - - ValidatorFactory vf = Validation.buildDefaultValidatorFactory(); - Validator validator = vf.getValidator(); - Set> set = validator.validate(callbackDTO); - for (final ConstraintViolation violation : set) { - return new Result<>(violation.getMessage(), null); - } - RetryerInfo retryerInfo = null; Object[] deSerialize = null; try { @@ -261,13 +252,6 @@ public class SnailRetryEndPoint { public Result idempotentIdGenerate(@Valid GenerateRetryIdempotentIdDTO generateRetryIdempotentIdDTO) { - ValidatorFactory vf = Validation.buildDefaultValidatorFactory(); - Validator validator = vf.getValidator(); - Set> set = validator.validate(generateRetryIdempotentIdDTO); - for (final ConstraintViolation violation : set) { - return new Result<>(violation.getMessage(), null); - } - String scene = generateRetryIdempotentIdDTO.getScene(); String executorName = generateRetryIdempotentIdDTO.getExecutorName(); String argsStr = generateRetryIdempotentIdDTO.getArgsStr();