File tree Expand file tree Collapse file tree 2 files changed +4
-7
lines changed
general-util/src/main/java/io/flamingock/internal/util/constants
mongodb-util/src/main/java/io/flamingock/mongodb/kit Expand file tree Collapse file tree 2 files changed +4
-7
lines changed Original file line number Diff line number Diff line change 1818public final class CommunityPersistenceConstants {
1919
2020 public static final String DEFAULT_AUDIT_STORE_NAME = "flamingockAuditLog" ;
21- public static final String DEFAULT_LOCK_STORE_NAME = "flamingockLocks " ;
21+ public static final String DEFAULT_LOCK_STORE_NAME = "flamingockLock " ;
2222 public static final String DEFAULT_MARKER_STORE_NAME = "flamingockAuditMarker" ;
2323
2424 private CommunityPersistenceConstants () {
Original file line number Diff line number Diff line change 2727import java .util .HashMap ;
2828import java .util .Map ;
2929
30+ import static io .flamingock .internal .util .constants .CommunityPersistenceConstants .DEFAULT_LOCK_STORE_NAME ;
31+
3032/**
3133 * MongoDB implementation of LockStorage for real database testing.
3234 * Only depends on MongoDB client/database and core Flamingock classes.
3335 * Does not depend on MongoDB-specific Flamingock components like MongoDBSyncTargetSystem.
3436 */
3537public class MongoDBSyncLockStorage implements LockStorage {
3638
37- private static final String LOCK_COLLECTION_NAME = "flamingockLocks" ;
38- private static final String METADATA_COLLECTION_NAME = "flamingockLockMetadata" ;
39-
40- private final MongoDatabase database ;
4139 private final MongoCollection <Document > lockCollection ;
4240 private final MongoCollection <Document > metadataCollection ;
4341
4442 public MongoDBSyncLockStorage (MongoDatabase database ) {
45- this (database , LOCK_COLLECTION_NAME );
43+ this (database , DEFAULT_LOCK_STORE_NAME );
4644 }
4745
4846 public MongoDBSyncLockStorage (MongoDatabase database , String lockCollectionName ) {
49- this .database = database ;
5047 this .lockCollection = database .getCollection (lockCollectionName );
5148 this .metadataCollection = database .getCollection (lockCollectionName + "Metadata" );
5249 }
You can’t perform that action at this time.
0 commit comments