Module org.neo4j.driver
Package org.neo4j.driver.internal.async
Class TerminationAwareBoltConnection
java.lang.Object
org.neo4j.driver.internal.async.TerminationAwareBoltConnection
- All Implemented Interfaces:
BoltConnection
-
Constructor Summary
ConstructorDescriptionTerminationAwareBoltConnection
(BoltConnection delegate, TerminationAwareStateLockingExecutor executor) -
Method Summary
Modifier and TypeMethodDescriptionauthData()
beginTransaction
(DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Set<String> bookmarks, TransactionType transactionType, Duration txTimeout, Map<String, Value> txMetadata, String txType, NotificationConfig notificationConfig) clear()
close()
commit()
discard
(long qid, long number) flush
(ResponseHandler handler) forceClose
(String reason) logoff()
pull
(long qid, long request) reset()
rollback()
route
(DatabaseName databaseName, String impersonatedUser, Set<String> bookmarks) runInAutoCommitTransaction
(DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Set<String> bookmarks, String query, Map<String, Value> parameters, Duration txTimeout, Map<String, Value> txMetadata, NotificationConfig notificationConfig) state()
telemetry
(TelemetryApi telemetryApi) boolean
-
Constructor Details
-
TerminationAwareBoltConnection
public TerminationAwareBoltConnection(BoltConnection delegate, TerminationAwareStateLockingExecutor executor)
-
-
Method Details
-
clearAndReset
-
telemetrySupported
public boolean telemetrySupported()- Specified by:
telemetrySupported
in interfaceBoltConnection
-
protocolVersion
- Specified by:
protocolVersion
in interfaceBoltConnection
-
serverAddress
- Specified by:
serverAddress
in interfaceBoltConnection
-
serverAgent
- Specified by:
serverAgent
in interfaceBoltConnection
-
authData
- Specified by:
authData
in interfaceBoltConnection
-
state
- Specified by:
state
in interfaceBoltConnection
-
close
- Specified by:
close
in interfaceBoltConnection
-
forceClose
- Specified by:
forceClose
in interfaceBoltConnection
-
flush
- Specified by:
flush
in interfaceBoltConnection
-
telemetry
- Specified by:
telemetry
in interfaceBoltConnection
-
clear
- Specified by:
clear
in interfaceBoltConnection
-
logon
- Specified by:
logon
in interfaceBoltConnection
-
logoff
- Specified by:
logoff
in interfaceBoltConnection
-
reset
- Specified by:
reset
in interfaceBoltConnection
-
rollback
- Specified by:
rollback
in interfaceBoltConnection
-
commit
- Specified by:
commit
in interfaceBoltConnection
-
discard
- Specified by:
discard
in interfaceBoltConnection
-
pull
- Specified by:
pull
in interfaceBoltConnection
-
run
- Specified by:
run
in interfaceBoltConnection
-
runInAutoCommitTransaction
public CompletionStage<BoltConnection> runInAutoCommitTransaction(DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Set<String> bookmarks, String query, Map<String, Value> parameters, Duration txTimeout, Map<String, Value> txMetadata, NotificationConfig notificationConfig) - Specified by:
runInAutoCommitTransaction
in interfaceBoltConnection
-
beginTransaction
public CompletionStage<BoltConnection> beginTransaction(DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Set<String> bookmarks, TransactionType transactionType, Duration txTimeout, Map<String, Value> txMetadata, String txType, NotificationConfig notificationConfig) - Specified by:
beginTransaction
in interfaceBoltConnection
-
route
public CompletionStage<BoltConnection> route(DatabaseName databaseName, String impersonatedUser, Set<String> bookmarks) - Specified by:
route
in interfaceBoltConnection
-