Module org.neo4j.bolt.connection.pooled

Package org.neo4j.bolt.connection.pooled

Class PooledBoltConnectionSource

java.lang.Object

org.neo4j.bolt.connection.pooled.PooledBoltConnectionSource

All Implemented Interfaces:

BoltConnectionSource<BoltConnectionParameters>

public class PooledBoltConnectionSource
extends Object
implements BoltConnectionSource<BoltConnectionParameters>

A pooled BoltConnectionSource implementation that automatically pools BoltConnection instances.

Since:

4.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	PooledBoltConnectionSource.TimeoutPolicy

Constructor Summary

Constructors

Constructor

Description

PooledBoltConnectionSource(LoggingProvider loggingProvider, Clock clock, URI uri, BoltConnectionProvider boltConnectionProvider, AuthTokenManager authTokenManager, SecurityPlanSupplier securityPlanSupplier, int maxSize, long acquisitionTimeout, long maxLifetime, long idleBeforeTest, PoolObservationProvider observationProvider, String routingContextAddress, BoltAgent boltAgent, String userAgent, int connectTimeoutMillis, NotificationConfig notificationConfig, PooledBoltConnectionSource.TimeoutPolicy timeoutPolicy)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	close()
CompletionStage<BoltConnection>	getConnection()
CompletionStage<BoltConnection>	getConnection(BoltConnectionParameters parameters)
void	onExpired()
CompletionStage<Boolean>	supportsMultiDb()
CompletionStage<Boolean>	supportsSessionAuth()
CompletionStage<Void>	verifyConnectivity()

Methods inherited from class java.lang.Object

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

Constructor Details

PooledBoltConnectionSource

public PooledBoltConnectionSource(LoggingProvider loggingProvider,
 Clock clock,
 URI uri,
 BoltConnectionProvider boltConnectionProvider,
 AuthTokenManager authTokenManager,
 SecurityPlanSupplier securityPlanSupplier,
 int maxSize,
 long acquisitionTimeout,
 long maxLifetime,
 long idleBeforeTest,
 PoolObservationProvider observationProvider,
 String routingContextAddress,
 BoltAgent boltAgent,
 String userAgent,
 int connectTimeoutMillis,
 NotificationConfig notificationConfig,
 PooledBoltConnectionSource.TimeoutPolicy timeoutPolicy)

Method Details

getConnection

public CompletionStage<BoltConnection> getConnection()

Specified by:

getConnection in interface BoltConnectionSource<BoltConnectionParameters>

getConnection

public CompletionStage<BoltConnection> getConnection(BoltConnectionParameters parameters)

Specified by:

getConnection in interface BoltConnectionSource<BoltConnectionParameters>

verifyConnectivity

public CompletionStage<Void> verifyConnectivity()

Specified by:

verifyConnectivity in interface BoltConnectionSource<BoltConnectionParameters>

supportsMultiDb

public CompletionStage<Boolean> supportsMultiDb()

Specified by:

supportsMultiDb in interface BoltConnectionSource<BoltConnectionParameters>

supportsSessionAuth

public CompletionStage<Boolean> supportsSessionAuth()

Specified by:

supportsSessionAuth in interface BoltConnectionSource<BoltConnectionParameters>

close

public CompletionStage<Void> close()

Specified by:

close in interface BoltConnectionSource<BoltConnectionParameters>

onExpired

public void onExpired()