io.flamingock.internal.core.transaction

Class TransactionManager<CLIENT_SESSION>

java.lang.Object

io.flamingock.internal.core.transaction.TransactionManager<CLIENT_SESSION>

public class TransactionManager<CLIENT_SESSION>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TransactionManager(java.util.function.Supplier<CLIENT_SESSION> clientSessionSupplier)

Method Summary

Modifier and Type	Method and Description
void	closeSession(java.lang.String sessionId)
java.util.Optional<CLIENT_SESSION>	getSession(java.lang.String sessionId)
CLIENT_SESSION	getSessionOrThrow(java.lang.String sessionId)
CLIENT_SESSION	startSession(java.lang.String sessionId) Starts a session, if not already created or is closed.
CLIENT_SESSION	startSession(java.lang.String sessionId, CLIENT_SESSION clientSession) Starts a session, if not already created or is closed.

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionManager

public TransactionManager(java.util.function.Supplier<CLIENT_SESSION> clientSessionSupplier)

Method Detail

startSession

public CLIENT_SESSION startSession(java.lang.String sessionId)

Starts a session, if not already created or is closed. Otherwise, it returns the existing one.

Parameters:

sessionId - ClientSession identifier. Will be the taskId most of the time(if not always)

Returns:

ClientSession

startSession

public CLIENT_SESSION startSession(java.lang.String sessionId,
                                   CLIENT_SESSION clientSession)

Starts a session, if not already created or is closed. Otherwise, it returns the existing one.

Parameters:

sessionId - ClientSession identifier. Will be the taskId most of the time(if not always)

clientSession - ClientSession instance

Returns:

ClientSession

closeSession

public void closeSession(java.lang.String sessionId)

getSession

public java.util.Optional<CLIENT_SESSION> getSession(java.lang.String sessionId)

getSessionOrThrow

public CLIENT_SESSION getSessionOrThrow(java.lang.String sessionId)