diff --git a/powerjob-remote/powerjob-remote-impl-http/pom.xml b/powerjob-remote/powerjob-remote-impl-http/pom.xml index 84577fad..3889bc56 100644 --- a/powerjob-remote/powerjob-remote-impl-http/pom.xml +++ b/powerjob-remote/powerjob-remote-impl-http/pom.xml @@ -29,21 +29,6 @@ ${powerjob-remote-framework.version} - - - io.vertx - vertx-core - ${vertx.version} - - - - io.vertx - vertx-web - ${vertx.version} - - - - \ No newline at end of file diff --git a/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpVertxCSInitializer.java b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpVertxCSInitializer.java index 9d37a6e8..0b715fb1 100644 --- a/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpVertxCSInitializer.java +++ b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpVertxCSInitializer.java @@ -1,16 +1,16 @@ package tech.powerjob.remote.http; import io.netty.handler.codec.http.HttpResponseStatus; -import io.vertx.core.Handler; -import io.vertx.core.Vertx; -import io.vertx.core.http.HttpClient; -import io.vertx.core.http.HttpServer; -import io.vertx.core.json.JsonObject; -import io.vertx.ext.web.RequestBody; -import io.vertx.ext.web.Route; -import io.vertx.ext.web.Router; -import io.vertx.ext.web.RoutingContext; -import io.vertx.ext.web.handler.BodyHandler; +import tech.powerjob.shade.io.vertx.core.Handler; +import tech.powerjob.shade.io.vertx.core.Vertx; +import tech.powerjob.shade.io.vertx.core.http.HttpClient; +import tech.powerjob.shade.io.vertx.core.http.HttpServer; +import tech.powerjob.shade.io.vertx.core.json.JsonObject; +import tech.powerjob.shade.io.vertx.ext.web.RequestBody; +import tech.powerjob.shade.io.vertx.ext.web.Route; +import tech.powerjob.shade.io.vertx.ext.web.Router; +import tech.powerjob.shade.io.vertx.ext.web.RoutingContext; +import tech.powerjob.shade.io.vertx.ext.web.handler.BodyHandler; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import tech.powerjob.common.exception.PowerJobException; diff --git a/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxInitializer.java b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxInitializer.java index 8d0eda3d..2066718d 100644 --- a/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxInitializer.java +++ b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxInitializer.java @@ -1,11 +1,11 @@ package tech.powerjob.remote.http.vertx; -import io.vertx.core.Vertx; -import io.vertx.core.VertxOptions; -import io.vertx.core.http.HttpClient; -import io.vertx.core.http.HttpClientOptions; -import io.vertx.core.http.HttpServer; -import io.vertx.core.http.HttpServerOptions; +import tech.powerjob.shade.io.vertx.core.Vertx; +import tech.powerjob.shade.io.vertx.core.VertxOptions; +import tech.powerjob.shade.io.vertx.core.http.HttpClient; +import tech.powerjob.shade.io.vertx.core.http.HttpClientOptions; +import tech.powerjob.shade.io.vertx.core.http.HttpServer; +import tech.powerjob.shade.io.vertx.core.http.HttpServerOptions; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import tech.powerjob.common.OmsConstant; @@ -50,7 +50,7 @@ public class VertxInitializer { // 非核心组件,不直接依赖类(无 import),加载报错可忽略 try { httpServerOptions - .addCompressor(io.netty.handler.codec.compression.StandardCompressionOptions.gzip()) + .addCompressor(tech.powerjob.shade.io.netty.handler.codec.compression.StandardCompressionOptions.gzip()) .setCompressionSupported(true); log.warn("[PowerJob-Vertx] enable server side compression successfully!"); } catch (Throwable t) { diff --git a/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxTransporter.java b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxTransporter.java index ddbd4be1..d56b3b0e 100644 --- a/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxTransporter.java +++ b/powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxTransporter.java @@ -3,13 +3,13 @@ package tech.powerjob.remote.http.vertx; import io.netty.handler.codec.http.HttpHeaderNames; import io.netty.handler.codec.http.HttpHeaderValues; import io.netty.handler.codec.http.HttpResponseStatus; -import io.vertx.core.Future; -import io.vertx.core.http.HttpClient; -import io.vertx.core.http.HttpClientRequest; -import io.vertx.core.http.HttpClientResponse; -import io.vertx.core.http.HttpMethod; -import io.vertx.core.http.RequestOptions; -import io.vertx.core.json.JsonObject; +import tech.powerjob.shade.io.vertx.core.Future; +import tech.powerjob.shade.io.vertx.core.http.HttpClient; +import tech.powerjob.shade.io.vertx.core.http.HttpClientRequest; +import tech.powerjob.shade.io.vertx.core.http.HttpClientResponse; +import tech.powerjob.shade.io.vertx.core.http.HttpMethod; +import tech.powerjob.shade.io.vertx.core.http.RequestOptions; +import tech.powerjob.shade.io.vertx.core.json.JsonObject; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.exception.ExceptionUtils; import tech.powerjob.common.PowerSerializable;