io.flamingock.store.mongodb.sync

Class MongoDBSyncAuditStore

java.lang.Object

io.flamingock.store.mongodb.sync.MongoDBSyncAuditStore

All Implemented Interfaces:

io.flamingock.api.external.ExternalSystem, io.flamingock.internal.common.core.context.ContextInitializable, io.flamingock.internal.core.external.store.AuditStore<io.flamingock.internal.core.external.store.audit.community.CommunityAuditPersistence>, io.flamingock.internal.core.external.store.CommunityAuditStore

public class MongoDBSyncAuditStore
extends java.lang.Object
implements io.flamingock.internal.core.external.store.CommunityAuditStore

Field Summary

Fields

Modifier and Type	Field and Description
protected io.flamingock.internal.util.id.RunnerId	runnerId

Method Summary

Modifier and Type	Method and Description
static MongoDBSyncAuditStore	from(io.flamingock.externalsystem.mongodb.api.MongoDBExternalSystem targetSystem) Creates a MongoDBSyncAuditStore using the same MongoDB client and database configured in the given MongoDBExternalSystem.
java.lang.String	getId()
io.flamingock.internal.core.external.store.lock.community.CommunityLockService	getLockService()
io.flamingock.internal.core.external.store.audit.community.CommunityAuditPersistence	getPersistence()
void	initialize(io.flamingock.internal.common.core.context.ContextResolver baseContext)
MongoDBSyncAuditStore	withAuditRepositoryName(java.lang.String auditRepositoryName)
MongoDBSyncAuditStore	withAutoCreate(boolean autoCreate)
MongoDBSyncAuditStore	withLockRepositoryName(java.lang.String lockRepositoryName)
MongoDBSyncAuditStore	withReadConcern(com.mongodb.ReadConcern readConcern)
MongoDBSyncAuditStore	withReadPreference(com.mongodb.ReadPreference readPreference)
MongoDBSyncAuditStore	withWriteConcern(com.mongodb.WriteConcern writeConcern)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

runnerId

protected io.flamingock.internal.util.id.RunnerId runnerId

Method Detail

from

public static MongoDBSyncAuditStore from(io.flamingock.externalsystem.mongodb.api.MongoDBExternalSystem targetSystem)

Creates a MongoDBSyncAuditStore using the same MongoDB client and database configured in the given MongoDBExternalSystem.

Only the underlying MongoDB instance (client + database name) is reused. No additional target-system configuration is carried over.

Parameters:

targetSystem - the target system from which to derive the client and database

Returns:

a new audit store bound to the same MongoDB instance as the target system

getId

public java.lang.String getId()

Specified by:

getId in interface io.flamingock.api.external.ExternalSystem

withAuditRepositoryName

public MongoDBSyncAuditStore withAuditRepositoryName(java.lang.String auditRepositoryName)

withLockRepositoryName

public MongoDBSyncAuditStore withLockRepositoryName(java.lang.String lockRepositoryName)

withReadConcern

public MongoDBSyncAuditStore withReadConcern(com.mongodb.ReadConcern readConcern)

withReadPreference

public MongoDBSyncAuditStore withReadPreference(com.mongodb.ReadPreference readPreference)

withWriteConcern

public MongoDBSyncAuditStore withWriteConcern(com.mongodb.WriteConcern writeConcern)

withAutoCreate

public MongoDBSyncAuditStore withAutoCreate(boolean autoCreate)

initialize

public void initialize(io.flamingock.internal.common.core.context.ContextResolver baseContext)

Specified by:

initialize in interface io.flamingock.internal.common.core.context.ContextInitializable

getPersistence

public io.flamingock.internal.core.external.store.audit.community.CommunityAuditPersistence getPersistence()

Specified by:

getPersistence in interface io.flamingock.internal.core.external.store.AuditStore<io.flamingock.internal.core.external.store.audit.community.CommunityAuditPersistence>

getLockService

public io.flamingock.internal.core.external.store.lock.community.CommunityLockService getLockService()

Specified by:

getLockService in interface io.flamingock.internal.core.external.store.CommunityAuditStore