Module org.neo4j.driver

Package org.neo4j.driver.internal.async

Class DelegatingBoltConnection

java.lang.Object

org.neo4j.driver.internal.async.DelegatingBoltConnection

All Implemented Interfaces:

BoltConnection

public abstract class DelegatingBoltConnection
extends Object
implements BoltConnection

Field Summary

Fields

Modifier and Type	Field	Description
protected final BoltConnection	delegate

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DelegatingBoltConnection(BoltConnection delegate)

Method Summary

Modifier and Type	Method	Description
CompletionStage<AuthData>	authData()
CompletionStage<BoltConnection>	beginTransaction(DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Set<String> bookmarks, TransactionType transactionType, Duration txTimeout, Map<String,Value> txMetadata, String txType, NotificationConfig notificationConfig)
CompletionStage<BoltConnection>	clear()
CompletionStage<Void>	close()
CompletionStage<BoltConnection>	commit()
CompletionStage<BoltConnection>	discard(long qid, long number)
CompletionStage<Void>	flush(ResponseHandler handler)
CompletionStage<Void>	forceClose(String reason)
CompletionStage<BoltConnection>	logoff()
CompletionStage<BoltConnection>	logon(Map<String,Value> authMap)
CompletionStage<BoltConnection>	onLoop()
BoltProtocolVersion	protocolVersion()
CompletionStage<BoltConnection>	pull(long qid, long request)
CompletionStage<BoltConnection>	reset()
CompletionStage<BoltConnection>	rollback()
CompletionStage<BoltConnection>	route(DatabaseName databaseName, String impersonatedUser, Set<String> bookmarks)
CompletionStage<BoltConnection>	run(String query, Map<String,Value> parameters)
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)
BoltServerAddress	serverAddress()
String	serverAgent()
BoltConnectionState	state()
CompletionStage<BoltConnection>	telemetry(TelemetryApi telemetryApi)
boolean	telemetrySupported()

Methods inherited from class java.lang.Object

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

Field Details

delegate

protected final BoltConnection delegate

Constructor Details

DelegatingBoltConnection

protected DelegatingBoltConnection(BoltConnection delegate)

Method Details

onLoop

public CompletionStage<BoltConnection> onLoop()

Specified by:

onLoop in interface BoltConnection

route

public CompletionStage<BoltConnection> route(DatabaseName databaseName,
 String impersonatedUser,
 Set<String> bookmarks)

Specified by:

route in interface BoltConnection

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 interface BoltConnection

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 interface BoltConnection

run

public CompletionStage<BoltConnection> run(String query,
 Map<String,Value> parameters)

Specified by:

run in interface BoltConnection

pull

public CompletionStage<BoltConnection> pull(long qid,
 long request)

Specified by:

pull in interface BoltConnection

discard

public CompletionStage<BoltConnection> discard(long qid,
 long number)

Specified by:

discard in interface BoltConnection

commit

public CompletionStage<BoltConnection> commit()

Specified by:

commit in interface BoltConnection

rollback

public CompletionStage<BoltConnection> rollback()

Specified by:

rollback in interface BoltConnection

reset

public CompletionStage<BoltConnection> reset()

Specified by:

reset in interface BoltConnection

logoff

public CompletionStage<BoltConnection> logoff()

Specified by:

logoff in interface BoltConnection

logon

public CompletionStage<BoltConnection> logon(Map<String,Value> authMap)

Specified by:

logon in interface BoltConnection

telemetry

public CompletionStage<BoltConnection> telemetry(TelemetryApi telemetryApi)

Specified by:

telemetry in interface BoltConnection

clear

public CompletionStage<BoltConnection> clear()

Specified by:

clear in interface BoltConnection

flush

public CompletionStage<Void> flush(ResponseHandler handler)

Specified by:

flush in interface BoltConnection

forceClose

public CompletionStage<Void> forceClose(String reason)

Specified by:

forceClose in interface BoltConnection

close

public CompletionStage<Void> close()

Specified by:

close in interface BoltConnection

state

public BoltConnectionState state()

Specified by:

state in interface BoltConnection

authData

public CompletionStage<AuthData> authData()

Specified by:

authData in interface BoltConnection

serverAgent

public String serverAgent()

Specified by:

serverAgent in interface BoltConnection

serverAddress

public BoltServerAddress serverAddress()

Specified by:

serverAddress in interface BoltConnection

protocolVersion

public BoltProtocolVersion protocolVersion()

Specified by:

protocolVersion in interface BoltConnection

telemetrySupported

public boolean telemetrySupported()

Specified by:

telemetrySupported in interface BoltConnection