io.flamingock.targetsystem.mongodb.springdata

Class MongoDBSpringDataTargetSystem

java.lang.Object

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

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

io.flamingock.targetsystem.mongodb.springdata.MongoDBSpringDataTargetSystem

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<MongoDBSpringDataTargetSystem>, io.flamingock.internal.common.core.context.ContextInitializable, io.flamingock.internal.common.core.context.ContextProvider

public class MongoDBSpringDataTargetSystem
extends io.flamingock.internal.core.external.targets.TransactionalTargetSystem<MongoDBSpringDataTargetSystem>
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
MongoDBSpringDataTargetSystem(java.lang.String id, org.springframework.data.mongodb.core.MongoTemplate mongoTemplate)

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.MongoDatabase	getMongoDatabase()
org.springframework.data.mongodb.core.MongoTemplate	getMongoTemplate()
com.mongodb.ReadConcern	getReadConcern()
com.mongodb.ReadPreference	getReadPreference()
protected MongoDBSpringDataTargetSystem	getSelf()
io.flamingock.internal.core.transaction.TransactionWrapper	getTxWrapper()
com.mongodb.WriteConcern	getWriteConcern()
void	initialize(io.flamingock.internal.common.core.context.ContextResolver baseContext)
MongoDBSpringDataTargetSystem	withReadConcern(com.mongodb.ReadConcern readConcern)
MongoDBSpringDataTargetSystem	withReadPreference(com.mongodb.ReadPreference readPreference)
MongoDBSpringDataTargetSystem	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

MongoDBSpringDataTargetSystem

public MongoDBSpringDataTargetSystem(java.lang.String id,
                                     org.springframework.data.mongodb.core.MongoTemplate mongoTemplate)

Method Detail

withReadConcern

public MongoDBSpringDataTargetSystem withReadConcern(com.mongodb.ReadConcern readConcern)

withReadPreference

public MongoDBSpringDataTargetSystem withReadPreference(com.mongodb.ReadPreference readPreference)

withWriteConcern

public MongoDBSpringDataTargetSystem withWriteConcern(com.mongodb.WriteConcern writeConcern)

getMongoTemplate

public org.springframework.data.mongodb.core.MongoTemplate getMongoTemplate()

getWriteConcern

public com.mongodb.WriteConcern getWriteConcern()

getReadConcern

public com.mongodb.ReadConcern getReadConcern()

getReadPreference

public com.mongodb.ReadPreference getReadPreference()

getMongoDatabase

public com.mongodb.client.MongoDatabase getMongoDatabase()

Specified by:

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

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 MongoDBSpringDataTargetSystem getSelf()

Specified by:

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

getTxWrapper

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

Specified by:

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

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<MongoDBSpringDataTargetSystem>