io.eventuate.tram.sagas.common

Class SagaLockManagerImpl

java.lang.Object

io.eventuate.tram.sagas.common.SagaLockManagerImpl

All Implemented Interfaces:

SagaLockManager

public class SagaLockManagerImpl
extends java.lang.Object
implements SagaLockManager

Constructor Summary

Constructors

Constructor and Description
SagaLockManagerImpl(io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor, io.eventuate.common.jdbc.EventuateSchema eventuateSchema)

Method Summary

Modifier and Type	Method and Description
boolean	claimLock(java.lang.String sagaType, java.lang.String sagaId, java.lang.String target)
java.lang.String	getDeleteFromSagaLockTableSql()
java.lang.String	getDeleteFromSagaStashTableSql()
java.lang.String	getInsertIntoSagaLockTableSql()
java.lang.String	getInsertIntoSagaStashTableSql()
java.lang.String	getSelectFromSagaLockTableSql()
java.lang.String	getSelectFromSagaStashTableSql()
java.lang.String	getUpdateSagaLockTableSql()
void	stashMessage(java.lang.String sagaType, java.lang.String sagaId, java.lang.String target, io.eventuate.tram.messaging.common.Message message)
java.util.Optional<io.eventuate.tram.messaging.common.Message>	unlock(java.lang.String sagaId, java.lang.String target)

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaLockManagerImpl

public SagaLockManagerImpl(io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor,
                           io.eventuate.common.jdbc.EventuateSchema eventuateSchema)

Method Detail

getInsertIntoSagaLockTableSql

public java.lang.String getInsertIntoSagaLockTableSql()

getInsertIntoSagaStashTableSql

public java.lang.String getInsertIntoSagaStashTableSql()

getSelectFromSagaLockTableSql

public java.lang.String getSelectFromSagaLockTableSql()

getSelectFromSagaStashTableSql

public java.lang.String getSelectFromSagaStashTableSql()

getUpdateSagaLockTableSql

public java.lang.String getUpdateSagaLockTableSql()

getDeleteFromSagaLockTableSql

public java.lang.String getDeleteFromSagaLockTableSql()

getDeleteFromSagaStashTableSql

public java.lang.String getDeleteFromSagaStashTableSql()

claimLock

public boolean claimLock(java.lang.String sagaType,
                         java.lang.String sagaId,
                         java.lang.String target)

Specified by:

claimLock in interface SagaLockManager

stashMessage

public void stashMessage(java.lang.String sagaType,
                         java.lang.String sagaId,
                         java.lang.String target,
                         io.eventuate.tram.messaging.common.Message message)

Specified by:

stashMessage in interface SagaLockManager

unlock

public java.util.Optional<io.eventuate.tram.messaging.common.Message> unlock(java.lang.String sagaId,
                                                                             java.lang.String target)

Specified by:

unlock in interface SagaLockManager