Module org.neo4j.driver

Package org.neo4j.driver.internal.async.connection

Class RoutingConnection

java.lang.Object

org.neo4j.driver.internal.async.connection.RoutingConnection

All Implemented Interfaces:

Connection

public class RoutingConnection
extends Object
implements Connection

A connection used by the routing driver.

Constructor Summary

Constructors

Constructor	Description
RoutingConnection(Connection delegate, org.neo4j.driver.internal.DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, org.neo4j.driver.internal.RoutingErrorHandler errorHandler)

Method Summary

Modifier and Type	Method	Description
void	bindTerminationAwareStateLockingExecutor(TerminationAwareStateLockingExecutor executor)
org.neo4j.driver.internal.DatabaseName	databaseName()
void	disableAutoRead()
void	enableAutoRead()
String	impersonatedUser()
boolean	isOpen()
boolean	isTelemetryEnabled()
AccessMode	mode()
BoltProtocol	protocol()
CompletionStage<Void>	release()
CompletionStage<Void>	reset(Throwable throwable)
org.neo4j.driver.internal.BoltServerAddress	serverAddress()
String	serverAgent()
void	terminateAndRelease(String reason)
void	write(Message message, ResponseHandler handler)
void	writeAndFlush(Message message, ResponseHandler handler)

Methods inherited from class java.lang.Object

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

Constructor Details

RoutingConnection

public RoutingConnection(Connection delegate,
 org.neo4j.driver.internal.DatabaseName databaseName,
 AccessMode accessMode,
 String impersonatedUser,
 org.neo4j.driver.internal.RoutingErrorHandler errorHandler)

Method Details

enableAutoRead

public void enableAutoRead()

Specified by:

enableAutoRead in interface Connection

disableAutoRead

public void disableAutoRead()

Specified by:

disableAutoRead in interface Connection

write

public void write(Message message,
 ResponseHandler handler)

Specified by:

write in interface Connection

writeAndFlush

public void writeAndFlush(Message message,
 ResponseHandler handler)

Specified by:

writeAndFlush in interface Connection

reset

public CompletionStage<Void> reset(Throwable throwable)

Specified by:

reset in interface Connection

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Connection

release

public CompletionStage<Void> release()

Specified by:

release in interface Connection

terminateAndRelease

public void terminateAndRelease(String reason)

Specified by:

terminateAndRelease in interface Connection

serverAgent

public String serverAgent()

Specified by:

serverAgent in interface Connection

serverAddress

public org.neo4j.driver.internal.BoltServerAddress serverAddress()

Specified by:

serverAddress in interface Connection

protocol

public BoltProtocol protocol()

Specified by:

protocol in interface Connection

bindTerminationAwareStateLockingExecutor

public void bindTerminationAwareStateLockingExecutor(TerminationAwareStateLockingExecutor executor)

Specified by:

bindTerminationAwareStateLockingExecutor in interface Connection

mode

public AccessMode mode()

Specified by:

mode in interface Connection

databaseName

public org.neo4j.driver.internal.DatabaseName databaseName()

Specified by:

databaseName in interface Connection

impersonatedUser

public String impersonatedUser()

Specified by:

impersonatedUser in interface Connection

isTelemetryEnabled

public boolean isTelemetryEnabled()

Specified by:

isTelemetryEnabled in interface Connection