diff --git a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/AbstractDistributeOnceElasticJobListener.java b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/AbstractDistributeOnceElasticJobListener.java index 33477e7127..69dbb66c8a 100644 --- a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/AbstractDistributeOnceElasticJobListener.java +++ b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/AbstractDistributeOnceElasticJobListener.java @@ -19,7 +19,7 @@ import lombok.Setter; import org.apache.shardingsphere.elasticjob.kernel.internal.util.BlockUtils; -import org.apache.shardingsphere.elasticjob.infra.env.TimeService; +import org.apache.shardingsphere.elasticjob.kernel.internal.time.TimeService; import org.apache.shardingsphere.elasticjob.infra.exception.JobSystemException; import org.apache.shardingsphere.elasticjob.infra.listener.ElasticJobListener; import org.apache.shardingsphere.elasticjob.infra.listener.ShardingContexts; diff --git a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/config/ConfigurationService.java b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/config/ConfigurationService.java index 4c37a4b0f1..c92cdefcfd 100644 --- a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/config/ConfigurationService.java +++ b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/config/ConfigurationService.java @@ -24,7 +24,7 @@ import org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO; import org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage; import org.apache.shardingsphere.elasticjob.reg.base.CoordinatorRegistryCenter; -import org.apache.shardingsphere.elasticjob.infra.env.TimeService; +import org.apache.shardingsphere.elasticjob.kernel.internal.time.TimeService; import org.apache.shardingsphere.elasticjob.infra.yaml.YamlEngine; /** diff --git a/infra/src/main/java/org/apache/shardingsphere/elasticjob/infra/env/TimeService.java b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/time/TimeService.java similarity index 93% rename from infra/src/main/java/org/apache/shardingsphere/elasticjob/infra/env/TimeService.java rename to kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/time/TimeService.java index 77236d6e33..1d08849a6f 100644 --- a/infra/src/main/java/org/apache/shardingsphere/elasticjob/infra/env/TimeService.java +++ b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/time/TimeService.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.shardingsphere.elasticjob.infra.env; +package org.apache.shardingsphere.elasticjob.kernel.internal.time; /** * Time service. diff --git a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/DistributeOnceElasticJobListenerTest.java b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/DistributeOnceElasticJobListenerTest.java index 11e55d116e..eebcfcf16f 100644 --- a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/DistributeOnceElasticJobListenerTest.java +++ b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/DistributeOnceElasticJobListenerTest.java @@ -18,7 +18,7 @@ package org.apache.shardingsphere.elasticjob.kernel.api.listener; import com.google.common.collect.Sets; -import org.apache.shardingsphere.elasticjob.infra.env.TimeService; +import org.apache.shardingsphere.elasticjob.kernel.internal.time.TimeService; import org.apache.shardingsphere.elasticjob.infra.exception.JobSystemException; import org.apache.shardingsphere.elasticjob.infra.listener.ShardingContexts; import org.apache.shardingsphere.elasticjob.kernel.api.listener.fixture.ElasticJobListenerCaller; diff --git a/infra/src/test/java/org/apache/shardingsphere/elasticjob/infra/env/TimeServiceTest.java b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/time/TimeServiceTest.java similarity index 89% rename from infra/src/test/java/org/apache/shardingsphere/elasticjob/infra/env/TimeServiceTest.java rename to kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/time/TimeServiceTest.java index bf08ba5e6b..6bac490370 100644 --- a/infra/src/test/java/org/apache/shardingsphere/elasticjob/infra/env/TimeServiceTest.java +++ b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/time/TimeServiceTest.java @@ -15,8 +15,9 @@ * limitations under the License. */ -package org.apache.shardingsphere.elasticjob.infra.env; +package org.apache.shardingsphere.elasticjob.kernel.time; +import org.apache.shardingsphere.elasticjob.kernel.internal.time.TimeService; import org.junit.jupiter.api.Test; import static org.junit.jupiter.api.Assertions.assertTrue;