diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/checker/ActiveVersionChecker.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/checker/ActiveVersionChecker.java index ff6a29dba7178..c10a93a87b1e3 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/checker/ActiveVersionChecker.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/checker/ActiveVersionChecker.java @@ -17,6 +17,8 @@ package org.apache.shardingsphere.mode.manager.cluster.dispatch.checker; +import lombok.AccessLevel; +import lombok.NoArgsConstructor; import org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions; import org.apache.shardingsphere.mode.event.DataChangedEvent; import org.apache.shardingsphere.mode.manager.ContextManager; @@ -24,10 +26,14 @@ /** * Active version checker. */ +@NoArgsConstructor(access = AccessLevel.PRIVATE) public final class ActiveVersionChecker { /** * Check active version. + * + * @param contextManager context manager + * @param event data changed event */ public static void checkActiveVersion(final ContextManager contextManager, final DataChangedEvent event) { ShardingSpherePreconditions.checkState(event.getValue().equals(contextManager.getPersistServiceFacade().getRepository().query(event.getKey())),