This is an automated email from the ASF dual-hosted git repository.
wmedvedeo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-apps.git
The following commit(s) were added to refs/heads/main by this push:
new 128e10bc3 [Fix #3901] Allow SSL in job service callback (#2215)
128e10bc3 is described below
commit 128e10bc3fead6bca3bd844ee7b1a3af90ceb19b
Author: Yohann Puyhaubert <[email protected]>
AuthorDate: Sat Jun 14 11:41:02 2025 +0200
[Fix #3901] Allow SSL in job service callback (#2215)
---
.../kogito/job/recipient/common/http/HTTPRequestExecutor.java | 10 +++-------
.../job/recipient/common/http/HTTPRequestExecutorTest.java | 4 ++--
2 files changed, 5 insertions(+), 9 deletions(-)
diff --git
a/jobs-service/jobs-recipients/job-recipient-common-http/src/main/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutor.java
b/jobs-service/jobs-recipients/job-recipient-common-http/src/main/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutor.java
index c1cc29ee1..09a8bfb67 100644
---
a/jobs-service/jobs-recipients/job-recipient-common-http/src/main/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutor.java
+++
b/jobs-service/jobs-recipients/job-recipient-common-http/src/main/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutor.java
@@ -18,14 +18,12 @@
*/
package org.kie.kogito.job.recipient.common.http;
-import java.net.URI;
import java.time.temporal.ChronoUnit;
import java.util.Collections;
import java.util.Map;
import java.util.stream.Collectors;
import org.kie.kogito.job.recipient.common.http.converters.HttpConverters;
-import org.kie.kogito.jobs.api.URIBuilder;
import org.kie.kogito.jobs.service.api.Recipient;
import org.kie.kogito.jobs.service.exception.JobExecutionException;
import org.kie.kogito.jobs.service.model.JobDetails;
@@ -104,11 +102,9 @@ public abstract class HTTPRequestExecutor<R extends
Recipient<?>> {
protected Uni<HttpResponse<Buffer>> executeRequest(HTTPRequest request,
long timeout) {
LOGGER.debug("Executing request {}", request);
- final URI uri = URIBuilder.toURI(request.getUrl());
- final HttpRequest<Buffer> clientRequest =
client.request(HttpConverters.convertHttpMethod(request.getMethod()),
- uri.getPort(),
- uri.getHost(),
- uri.getPath()).timeout(timeout);
+ final HttpRequest<Buffer> clientRequest =
client.requestAbs(HttpConverters.convertHttpMethod(
+ request.getMethod()),
+ request.getUrl()).timeout(timeout);
clientRequest.queryParams().addAll(filterEntries(request.getQueryParams()));
clientRequest.headers().addAll(filterEntries(request.getHeaders()));
if (request.getBody() != null) {
diff --git
a/jobs-service/jobs-recipients/job-recipient-common-http/src/test/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutorTest.java
b/jobs-service/jobs-recipients/job-recipient-common-http/src/test/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutorTest.java
index bf20d05a7..364e5b406 100644
---
a/jobs-service/jobs-recipients/job-recipient-common-http/src/test/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutorTest.java
+++
b/jobs-service/jobs-recipients/job-recipient-common-http/src/test/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutorTest.java
@@ -146,7 +146,7 @@ public abstract class HTTPRequestExecutorTest<R extends
Recipient<?>, E extends
@SuppressWarnings("unchecked")
private Map<String, String>[]
executeAndCollectRequestInfo(HttpRequest<Buffer> request, MultiMap params,
MultiMap headers,
JobDetails scheduledJob, boolean mockError) {
- doReturn(request).when(webClient).request(HttpMethod.POST, PORT, HOST,
PATH);
+ doReturn(request).when(webClient).requestAbs(HttpMethod.POST,
ENDPOINT);
doReturn(request).when(request).timeout(anyLong());
doReturn(params).when(request).queryParams();
doReturn(headers).when(request).headers();
@@ -157,7 +157,7 @@ public abstract class HTTPRequestExecutorTest<R extends
Recipient<?>, E extends
doReturn(Uni.createFrom().item(httpResponse)).when(request).sendBuffer(any());
JobExecutionResponse response =
tested.execute(scheduledJob).onFailure().recoverWithNull().await().indefinitely();
- verify(webClient).request(HttpMethod.POST, PORT, HOST, PATH);
+ verify(webClient).requestAbs(HttpMethod.POST, ENDPOINT);
verify(request).sendBuffer(bufferCaptor.capture());
verify(request).queryParams();
verify(request).headers();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
