Adapt to vertx-core internal packages

vert-x3 · Jun 19, 2024 · fe0fc17 · fe0fc17
1 parent c3b9bda
commit fe0fc17
Show file tree

Hide file tree

Showing 8 changed files with 12 additions and 15 deletions.
diff --git a/src/main/java/io/vertx/kafka/admin/impl/KafkaAdminClientImpl.java b/src/main/java/io/vertx/kafka/admin/impl/KafkaAdminClientImpl.java
@@ -30,7 +30,7 @@
 import java.util.stream.Collectors;
 
 import io.vertx.core.Promise;
-import io.vertx.core.impl.ContextInternal;
+import io.vertx.core.internal.ContextInternal;
 import io.vertx.kafka.admin.ClusterDescription;
 import io.vertx.kafka.admin.Config;
 import io.vertx.kafka.admin.ConsumerGroupDescription;

diff --git a/src/main/java/io/vertx/kafka/client/common/impl/CloseHandler.java b/src/main/java/io/vertx/kafka/client/common/impl/CloseHandler.java
@@ -17,11 +17,10 @@
 
 import io.vertx.core.AsyncResult;
 import io.vertx.core.Closeable;
-import io.vertx.core.Context;
 import io.vertx.core.Future;
 import io.vertx.core.Handler;
-import io.vertx.core.impl.ContextInternal;
-import io.vertx.core.impl.VertxInternal;
+import io.vertx.core.internal.ContextInternal;
+import io.vertx.core.internal.VertxInternal;
 
 import java.util.function.BiConsumer;
 import java.util.function.Consumer;

diff --git a/src/main/java/io/vertx/kafka/client/consumer/impl/KafkaConsumerImpl.java b/src/main/java/io/vertx/kafka/client/consumer/impl/KafkaConsumerImpl.java
@@ -17,7 +17,7 @@
 package io.vertx.kafka.client.consumer.impl;
 
 import io.vertx.core.*;
-import io.vertx.core.impl.ContextInternal;
+import io.vertx.core.internal.ContextInternal;
 import io.vertx.kafka.client.consumer.OffsetAndTimestamp;
 import io.vertx.kafka.client.common.impl.CloseHandler;
 import io.vertx.kafka.client.common.impl.Helper;

diff --git a/src/main/java/io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.java b/src/main/java/io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.java
@@ -22,7 +22,7 @@
 import io.vertx.core.Handler;
 import io.vertx.core.Promise;
 import io.vertx.core.Vertx;
-import io.vertx.core.impl.ContextInternal;
+import io.vertx.core.internal.ContextInternal;
 import io.vertx.kafka.client.common.KafkaClientOptions;
 import io.vertx.kafka.client.common.impl.Helper;
 import io.vertx.kafka.client.common.tracing.ConsumerTracer;

diff --git a/src/main/java/io/vertx/kafka/client/producer/impl/KafkaProducerImpl.java b/src/main/java/io/vertx/kafka/client/producer/impl/KafkaProducerImpl.java
@@ -17,9 +17,9 @@
 package io.vertx.kafka.client.producer.impl;
 
 import io.vertx.core.*;
-import io.vertx.core.impl.CloseFuture;
-import io.vertx.core.impl.ContextInternal;
-import io.vertx.core.impl.VertxInternal;
+import io.vertx.core.internal.CloseFuture;
+import io.vertx.core.internal.ContextInternal;
+import io.vertx.core.internal.VertxInternal;
 import io.vertx.kafka.client.common.KafkaClientOptions;
 import io.vertx.kafka.client.common.PartitionInfo;
 import io.vertx.kafka.client.common.impl.CloseHandler;

diff --git a/src/main/java/io/vertx/kafka/client/producer/impl/KafkaWriteStreamImpl.java b/src/main/java/io/vertx/kafka/client/producer/impl/KafkaWriteStreamImpl.java
@@ -16,15 +16,13 @@
 
 package io.vertx.kafka.client.producer.impl;
 
-import io.vertx.core.AsyncResult;
-import io.vertx.core.Context;
 import io.vertx.core.Future;
 import io.vertx.core.Handler;
 import io.vertx.core.Promise;
 import io.vertx.core.Vertx;
-import io.vertx.core.impl.ContextInternal;
+import io.vertx.core.internal.ContextInternal;
 import io.vertx.core.impl.TaskQueue;
-import io.vertx.core.impl.VertxInternal;
+import io.vertx.core.internal.VertxInternal;
 import io.vertx.kafka.client.common.KafkaClientOptions;
 import io.vertx.kafka.client.common.tracing.ProducerTracer;
 import io.vertx.kafka.client.producer.KafkaWriteStream;

diff --git a/src/test/java/io/vertx/kafka/client/tests/ProducerConsumerContextTest.java b/src/test/java/io/vertx/kafka/client/tests/ProducerConsumerContextTest.java
@@ -19,7 +19,7 @@
 import io.vertx.core.AbstractVerticle;
 import io.vertx.core.Context;
 import io.vertx.core.Vertx;
-import io.vertx.core.impl.ContextInternal;
+import io.vertx.core.internal.ContextInternal;
 import io.vertx.ext.unit.Async;
 import io.vertx.ext.unit.TestContext;
 import io.vertx.kafka.client.consumer.KafkaReadStream;

diff --git a/src/test/java/io/vertx/kafka/client/tests/ProducerTest.java b/src/test/java/io/vertx/kafka/client/tests/ProducerTest.java
@@ -18,7 +18,7 @@
 
 import io.vertx.core.Context;
 import io.vertx.core.Vertx;
-import io.vertx.core.impl.ContextInternal;
+import io.vertx.core.internal.ContextInternal;
 import io.vertx.ext.unit.Async;
 import io.vertx.ext.unit.TestContext;
 import io.vertx.kafka.client.producer.KafkaProducer;