Module org.neo4j.bolt.connection.pooled

Package org.neo4j.bolt.connection.pooled.impl

Class PooledBoltConnection

java.lang.Object

org.neo4j.bolt.connection.pooled.impl.PooledBoltConnection

All Implemented Interfaces:

BoltConnection

public class PooledBoltConnection
extends Object
implements BoltConnection

Constructor Summary

Constructors

Constructor	Description
PooledBoltConnection(BoltConnection delegate, PooledBoltConnectionSource source, Runnable releaseRunnable, Runnable purgeRunnable, Function<ImmutableObservation,Observation> inUseObservationFunction)

Method Summary

Modifier and Type	Method	Description
CompletionStage<AuthInfo>	authInfo()
CompletionStage<Void>	close()
Optional<Duration>	defaultReadTimeout()
BoltConnection	delegate()
CompletionStage<Void>	forceClose(String reason)
void	onUsageStart(ImmutableObservation observationParent)
BoltProtocolVersion	protocolVersion()
BoltServerAddress	serverAddress()
String	serverAgent()
boolean	serverSideRoutingEnabled()
CompletionStage<Void>	setReadTimeout(Duration duration)
BoltConnectionState	state()
boolean	telemetrySupported()
CompletionStage<Void>	write(List<Message> messages)
CompletionStage<Void>	writeAndFlush(ResponseHandler handler, List<Message> messages, ImmutableObservation parentObservation)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.neo4j.bolt.connection.BoltConnection

write, writeAndFlush

Constructor Details

PooledBoltConnection

public PooledBoltConnection(BoltConnection delegate,
 PooledBoltConnectionSource source,
 Runnable releaseRunnable,
 Runnable purgeRunnable,
 Function<ImmutableObservation,Observation> inUseObservationFunction)

Method Details

writeAndFlush

public CompletionStage<Void> writeAndFlush(ResponseHandler handler,
 List<Message> messages,
 ImmutableObservation parentObservation)

Specified by:

writeAndFlush in interface BoltConnection

write

public CompletionStage<Void> write(List<Message> messages)

Specified by:

write 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

setReadTimeout

public CompletionStage<Void> setReadTimeout(Duration duration)

Specified by:

setReadTimeout in interface BoltConnection

state

public BoltConnectionState state()

Specified by:

state in interface BoltConnection

authInfo

public CompletionStage<AuthInfo> authInfo()

Specified by:

authInfo 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

serverSideRoutingEnabled

public boolean serverSideRoutingEnabled()

Specified by:

serverSideRoutingEnabled in interface BoltConnection

defaultReadTimeout

public Optional<Duration> defaultReadTimeout()

Specified by:

defaultReadTimeout in interface BoltConnection

delegate

public BoltConnection delegate()

onUsageStart

public void onUsageStart(ImmutableObservation observationParent)