io.flamingock.targetsystem.mongodb.sync

Class MongoDBSyncTargetSystem

java.lang.Object

io.flamingock.internal.core.external.targets.AbstractTargetSystem<HOLDER>

io.flamingock.internal.core.external.targets.TransactionalTargetSystem<MongoDBSyncTargetSystem>

io.flamingock.targetsystem.mongodb.sync.MongoDBSyncTargetSystem

All Implemented Interfaces:

io.flamingock.api.external.ExternalSystem, io.flamingock.api.external.TargetSystem, io.flamingock.externalsystem.mongodb.api.MongoDBExternalSystem, io.flamingock.internal.common.core.context.ContextConfigurable<MongoDBSyncTargetSystem>, io.flamingock.internal.common.core.context.ContextInitializable, io.flamingock.internal.common.core.context.ContextProvider

public class MongoDBSyncTargetSystem
extends io.flamingock.internal.core.external.targets.TransactionalTargetSystem<MongoDBSyncTargetSystem>
implements io.flamingock.externalsystem.mongodb.api.MongoDBExternalSystem

Field Summary

Fields inherited from class io.flamingock.internal.core.external.targets.TransactionalTargetSystem

autoCreate, markerRepository, onGoingTasksRepositoryName

Fields inherited from class io.flamingock.internal.core.external.targets.AbstractTargetSystem

targetSystemContext

Constructor Summary

Constructors

Constructor and Description
MongoDBSyncTargetSystem(java.lang.String id, com.mongodb.client.MongoClient mongoClient, java.lang.String databaseName)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<io.flamingock.internal.common.core.audit.AuditHistoryReader>	getAuditAuditReader(io.flamingock.internal.common.core.audit.AuditReaderType type)
com.mongodb.client.MongoClient	getClient()
java.lang.String	getDatabaseName()
com.mongodb.client.MongoDatabase	getMongoDatabase()
com.mongodb.ReadConcern	getReadConcern()
com.mongodb.ReadPreference	getReadPreference()
protected MongoDBSyncTargetSystem	getSelf()
io.flamingock.internal.core.transaction.TransactionManager<com.mongodb.client.ClientSession>	getTxManager()
io.flamingock.internal.core.transaction.TransactionWrapper	getTxWrapper()
com.mongodb.WriteConcern	getWriteConcern()
void	initialize(io.flamingock.internal.common.core.context.ContextResolver baseContext)
MongoDBSyncTargetSystem	withReadConcern(com.mongodb.ReadConcern readConcern)
MongoDBSyncTargetSystem	withReadPreference(com.mongodb.ReadPreference readPreference)
MongoDBSyncTargetSystem	withWriteConcern(com.mongodb.WriteConcern writeConcern)

Methods inherited from class io.flamingock.internal.core.external.targets.TransactionalTargetSystem

applyChangeTransactional, getOnGoingTaskStatusRepository, hasMarker

Methods inherited from class io.flamingock.internal.core.external.targets.AbstractTargetSystem

addDependency, addDependency, addDependency, addDependency, applyChange, enhanceExecutionRuntime, getContext, getId, rollbackChange, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.flamingock.api.external.ExternalSystem

getId

Constructor Detail

MongoDBSyncTargetSystem

public MongoDBSyncTargetSystem(java.lang.String id,
                               com.mongodb.client.MongoClient mongoClient,
                               java.lang.String databaseName)

Method Detail

withReadConcern

public MongoDBSyncTargetSystem withReadConcern(com.mongodb.ReadConcern readConcern)

withReadPreference

public MongoDBSyncTargetSystem withReadPreference(com.mongodb.ReadPreference readPreference)

withWriteConcern

public MongoDBSyncTargetSystem withWriteConcern(com.mongodb.WriteConcern writeConcern)

getClient

public com.mongodb.client.MongoClient getClient()

getMongoDatabase

public com.mongodb.client.MongoDatabase getMongoDatabase()

Specified by:

getMongoDatabase in interface io.flamingock.externalsystem.mongodb.api.MongoDBExternalSystem

getDatabaseName

public java.lang.String getDatabaseName()

getWriteConcern

public com.mongodb.WriteConcern getWriteConcern()

getReadConcern

public com.mongodb.ReadConcern getReadConcern()

getReadPreference

public com.mongodb.ReadPreference getReadPreference()

getTxManager

public io.flamingock.internal.core.transaction.TransactionManager<com.mongodb.client.ClientSession> getTxManager()

initialize

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

Specified by:

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

getSelf

protected MongoDBSyncTargetSystem getSelf()

Specified by:

getSelf in class io.flamingock.internal.core.external.targets.AbstractTargetSystem<MongoDBSyncTargetSystem>

getTxWrapper

public io.flamingock.internal.core.transaction.TransactionWrapper getTxWrapper()

Specified by:

getTxWrapper in class io.flamingock.internal.core.external.targets.TransactionalTargetSystem<MongoDBSyncTargetSystem>

getAuditAuditReader

public java.util.Optional<io.flamingock.internal.common.core.audit.AuditHistoryReader> getAuditAuditReader(io.flamingock.internal.common.core.audit.AuditReaderType type)

Overrides:

getAuditAuditReader in class io.flamingock.internal.core.external.targets.TransactionalTargetSystem<MongoDBSyncTargetSystem>