Package org.apache.tinkerpop.gremlin.server.handler

Class TransactionManager

java.lang.Object

org.apache.tinkerpop.gremlin.server.handler.TransactionManager

public class TransactionManager
extends Object

Tracks active transactions and returns references of them.

Constructor Summary

Constructors

Constructor	Description
TransactionManager(ScheduledExecutorService scheduledExecutorService, GraphManager graphManager, long transactionTimeoutMs, int maxConcurrentTransactions, long perGraphCloseMs)	Creates a new TransactionManager with the specified configuration.

Method Summary

Modifier and Type	Method	Description
UnmanagedTransaction	create(String traversalSourceName)	Creates a new UnmanagedTransaction for the specified traversal source.
void	destroy(String id)	Removes a transaction from the active transactions map.
Optional<UnmanagedTransaction>	get(String transactionId)	Gets an existing UnmanagedTransaction by ID.
int	getActiveTransactionCount()	Returns the number of currently active transactions.
void	shutdown()	Shuts down the transaction manager, rolling back all active transactions.

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionManager

public TransactionManager(ScheduledExecutorService scheduledExecutorService,
                          GraphManager graphManager,
                          long transactionTimeoutMs,
                          int maxConcurrentTransactions,
                          long perGraphCloseMs)

Creates a new TransactionManager with the specified configuration.

Parameters:

scheduledExecutorService - Scheduler for timeout management

graphManager - The graph manager for accessing traversal sources

transactionTimeoutMs - Timeout in milliseconds before auto-rollback

maxConcurrentTransactions - Maximum number of concurrent transactions allowed

Method Detail

create

public UnmanagedTransaction create(String traversalSourceName)

Creates a new UnmanagedTransaction for the specified traversal source.

Parameters:

traversalSourceName - The traversal source alias (e.g., "g")

Returns:

The new UnmanagedTransaction, ready for task submission

Throws:

IllegalStateException - if max transactions exceeded

IllegalArgumentException - if traversal source not found

UnsupportedOperationException - if the graph does not support transactions

destroy

public void destroy(String id)

Removes a transaction from the active transactions map. Called when a transaction is committed, rolled back, or otherwise closed.

Parameters:

id - The transaction ID to remove

get

public Optional<UnmanagedTransaction> get(String transactionId)

Gets an existing UnmanagedTransaction by ID.

Parameters:

transactionId - The transaction ID to look up

Returns:

Optional containing the UnmanagedTransaction if found, empty otherwise

getActiveTransactionCount

public int getActiveTransactionCount()

Returns the number of currently active transactions.

Returns:

the count of active transactions

shutdown

public void shutdown()

Shuts down the transaction manager, rolling back all active transactions.

This method should be called during server shutdown to ensure all transactions are properly cleaned up. It blocks until all rollbacks complete.