java.lang.Object
org.neo4j.driver.internal.async.UnmanagedTransaction
- All Implemented Interfaces:
TerminationAwareStateLockingExecutor
-
Field Summary
-
Constructor Summary
ModifierConstructorDescriptionprotected
UnmanagedTransaction
(BoltConnection connection, DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer, long fetchSize, ResultCursorsHolder resultCursors, NotificationConfig notificationConfig, ApiTelemetryWork apiTelemetryWork, Logging logging) UnmanagedTransaction
(BoltConnection connection, DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer, long fetchSize, NotificationConfig notificationConfig, ApiTelemetryWork apiTelemetryWork, Logging logging) -
Method Summary
Modifier and TypeMethodDescriptionbeginAsync
(Set<Bookmark> initialBookmarks, TransactionConfig config, String txType, boolean flush) closeAsync
(boolean commit) <T> T
Locks the state and executes the suppliedConsumer
with a cause of termination if the state is terminated.boolean
isOpen()
void
markTerminated
(Throwable cause)
-
Field Details
-
EXPLICITLY_TERMINATED_MSG
- See Also:
-
CANT_COMMIT_COMMITTED_MSG
- See Also:
-
CANT_ROLLBACK_COMMITTED_MSG
- See Also:
-
CANT_COMMIT_ROLLED_BACK_MSG
- See Also:
-
CANT_ROLLBACK_ROLLED_BACK_MSG
- See Also:
-
CANT_COMMIT_ROLLING_BACK_MSG
- See Also:
-
CANT_ROLLBACK_COMMITTING_MSG
- See Also:
-
-
Constructor Details
-
UnmanagedTransaction
public UnmanagedTransaction(BoltConnection connection, DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer, long fetchSize, NotificationConfig notificationConfig, ApiTelemetryWork apiTelemetryWork, Logging logging) -
UnmanagedTransaction
protected UnmanagedTransaction(BoltConnection connection, DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, 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
-
closeAsync
-
commitAsync
-
rollbackAsync
-
runAsync
-
runRx
-
isOpen
public boolean isOpen() -
markTerminated
-
connection
-
terminateAsync
-
execute
Description copied from interface:TerminationAwareStateLockingExecutor
Locks the state and executes the suppliedConsumer
with a cause of termination if the state is terminated.- Specified by:
execute
in interfaceTerminationAwareStateLockingExecutor
- Parameters:
causeOfTerminationConsumer
- the consumer accepting
-