Skip to content

Commit b4308fe

Browse files
Fix compatibility issue with Vert.x 5 (#625) (#627)
1 parent 1c8ccff commit b4308fe

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

sdk-http-vertx/src/main/java/dev/restate/sdk/http/vertx/HttpEndpointRequestHandler.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,10 @@
2020
import io.reactiverse.contextual.logging.ContextualData;
2121
import io.vertx.core.Context;
2222
import io.vertx.core.Handler;
23+
import io.vertx.core.Vertx;
2324
import io.vertx.core.http.HttpServerRequest;
2425
import io.vertx.core.http.HttpServerResponse;
2526
import io.vertx.core.http.HttpVersion;
26-
import io.vertx.core.http.impl.HttpServerRequestInternal;
2727
import java.net.URI;
2828
import java.util.concurrent.Executor;
2929
import org.apache.logging.log4j.LogManager;
@@ -50,7 +50,9 @@ private HttpEndpointRequestHandler(Endpoint endpoint, boolean enableBidirectiona
5050
@Override
5151
public void handle(HttpServerRequest request) {
5252
URI uri = URI.create(request.uri());
53-
Context vertxCurrentContext = ((HttpServerRequestInternal) request).context();
53+
// The handler is dispatched by Vert.x on the request's event-loop context, so the current
54+
// context is the same instance as ((HttpServerRequestInternal) request).context().
55+
Context vertxCurrentContext = Vertx.currentContext();
5456

5557
RequestProcessor requestProcessor;
5658
try {

0 commit comments

Comments
 (0)