in jobs-service/jobs-recipients/job-http-recipient/runtime/src/main/java/org/kie/kogito/job/http/recipient/HttpRecipientValidator.java [50:70]
public void validate(Recipient<?> recipient, ValidatorContext context) {
if (!(recipient instanceof HttpRecipient)) {
throw new ValidationException("Recipient must be a non-null instance of: " + HttpRecipient.class + ".");
}
HttpRecipient<?> httpRecipient = (HttpRecipient<?>) recipient;
if (ConversionUtils.isEmpty(httpRecipient.getUrl())) {
throw new ValidationException("HttpRecipient url must have a non empty value.");
}
try {
new URL(httpRecipient.getUrl());
} catch (MalformedURLException e) {
throw new ValidationException("HttpRecipient must have a valid url.", e);
}
if (context.getJob() != null) {
Long timeoutInMillis = ModelUtil.getExecutionTimeoutInMillis(context.getJob());
if (timeoutInMillis != null && timeoutInMillis > maxTimeoutInMillis) {
throw new ValidationException("Job executionTimeout configuration can not exceed the HttpRecipient max-timeout-in-millis: " + maxTimeoutInMillis +
", but is: " + timeoutInMillis + ".");
}
}
}