Module org.neo4j.driver

Package org.neo4j.driver.internal.async

Class UnmanagedTransaction

java.lang.Object

org.neo4j.driver.internal.async.UnmanagedTransaction

All Implemented Interfaces:

TerminationAwareStateLockingExecutor

public class UnmanagedTransaction
extends Object
implements TerminationAwareStateLockingExecutor

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	CANT_COMMIT_COMMITTED_MSG
protected static final String	CANT_COMMIT_ROLLED_BACK_MSG
protected static final String	CANT_COMMIT_ROLLING_BACK_MSG
protected static final String	CANT_ROLLBACK_COMMITTED_MSG
protected static final String	CANT_ROLLBACK_COMMITTING_MSG
protected static final String	CANT_ROLLBACK_ROLLED_BACK_MSG
static final String	EXPLICITLY_TERMINATED_MSG

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	UnmanagedTransaction(Connection connection, Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer, long fetchSize, ResultCursorsHolder resultCursors, NotificationConfig notificationConfig, ApiTelemetryWork apiTelemetryWork, Logging logging)
	UnmanagedTransaction(Connection connection, Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer, long fetchSize, NotificationConfig notificationConfig, ApiTelemetryWork apiTelemetryWork, Logging logging)

Method Summary

Modifier and Type	Method	Description
CompletionStage<UnmanagedTransaction>	beginAsync(Set<Bookmark> initialBookmarks, TransactionConfig config, String txType, boolean flush)
CompletionStage<Void>	closeAsync()
CompletionStage<Void>	closeAsync(boolean commit)
CompletionStage<Void>	commitAsync()
Connection	connection()
void	execute(Consumer<Throwable> causeOfTerminationConsumer)	Locks the state and executes the supplied Consumer with a cause of termination if the state is terminated.
boolean	isOpen()
Throwable	markTerminated(Throwable cause)
CompletionStage<Void>	rollbackAsync()
CompletionStage<ResultCursor>	runAsync(Query query)
CompletionStage<RxResultCursor>	runRx(Query query)
CompletionStage<Void>	terminateAsync()

Methods inherited from class java.lang.Object

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

Field Details

EXPLICITLY_TERMINATED_MSG

public static final String EXPLICITLY_TERMINATED_MSG

See Also:

• Constant Field Values

CANT_COMMIT_COMMITTED_MSG

protected static final String CANT_COMMIT_COMMITTED_MSG

See Also:

• Constant Field Values

CANT_ROLLBACK_COMMITTED_MSG

protected static final String CANT_ROLLBACK_COMMITTED_MSG

See Also:

• Constant Field Values

CANT_COMMIT_ROLLED_BACK_MSG

protected static final String CANT_COMMIT_ROLLED_BACK_MSG

See Also:

• Constant Field Values

CANT_ROLLBACK_ROLLED_BACK_MSG

protected static final String CANT_ROLLBACK_ROLLED_BACK_MSG

See Also:

• Constant Field Values

CANT_COMMIT_ROLLING_BACK_MSG

protected static final String CANT_COMMIT_ROLLING_BACK_MSG

See Also:

• Constant Field Values

CANT_ROLLBACK_COMMITTING_MSG

protected static final String CANT_ROLLBACK_COMMITTING_MSG

See Also:

• Constant Field Values

Constructor Details

UnmanagedTransaction

public UnmanagedTransaction(Connection connection,
 Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer,
 long fetchSize,
 NotificationConfig notificationConfig,
 ApiTelemetryWork apiTelemetryWork,
 Logging logging)

UnmanagedTransaction

protected UnmanagedTransaction(Connection connection,
 Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer,
 long fetchSize,
 ResultCursorsHolder resultCursors,
 NotificationConfig notificationConfig,
 ApiTelemetryWork apiTelemetryWork,
 Logging logging)

Method Details

beginAsync

public CompletionStage<UnmanagedTransaction> beginAsync(Set<Bookmark> initialBookmarks,
 TransactionConfig config,
 String txType,
 boolean flush)

closeAsync

public CompletionStage<Void> closeAsync()

closeAsync

public CompletionStage<Void> closeAsync(boolean commit)

commitAsync

public CompletionStage<Void> commitAsync()

rollbackAsync

public CompletionStage<Void> rollbackAsync()

runAsync

public CompletionStage<ResultCursor> runAsync(Query query)

runRx

public CompletionStage<RxResultCursor> runRx(Query query)

isOpen

public boolean isOpen()

markTerminated

public Throwable markTerminated(Throwable cause)

connection

public Connection connection()

execute

public void execute(Consumer<Throwable> causeOfTerminationConsumer)

Description copied from interface: TerminationAwareStateLockingExecutor

Locks the state and executes the supplied Consumer with a cause of termination if the state is terminated.

Specified by:

execute in interface TerminationAwareStateLockingExecutor

Parameters:

causeOfTerminationConsumer - the consumer accepting

terminateAsync

public CompletionStage<Void> terminateAsync()