Module org.neo4j.bolt.connection.pooled

Package org.neo4j.bolt.connection.pooled

Class PooledBoltConnectionProvider

java.lang.Object

org.neo4j.bolt.connection.pooled.PooledBoltConnectionProvider

All Implemented Interfaces:

BoltConnectionProvider

public class PooledBoltConnectionProvider
extends Object
implements BoltConnectionProvider

Constructor Summary

Constructors

Constructor	Description
PooledBoltConnectionProvider(BoltConnectionProvider boltConnectionProvider, int maxSize, long acquisitionTimeout, long maxLifetime, long idleBeforeTest, Clock clock, LoggingProvider logging, MetricsListener metricsListener, BoltServerAddress address, RoutingContext routingContext, BoltAgent boltAgent, String userAgent, int connectTimeoutMillis)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	close()
CompletionStage<BoltConnection>	connect(BoltServerAddress ignoredAddress, RoutingContext ignoredRoutingContext, BoltAgent ignoredBoltAgent, String ignoredUserAgent, int ignoredConnectTimeoutMillis, SecurityPlan securityPlan, DatabaseName databaseName, Supplier<CompletionStage<AuthToken>> authTokenStageSupplier, AccessMode mode, Set<String> bookmarks, String impersonatedUser, BoltProtocolVersion minVersion, NotificationConfig notificationConfig, Consumer<DatabaseName> databaseNameConsumer, Map<String,Object> additionalParameters)
void	onExpired()
CompletionStage<Boolean>	supportsMultiDb(BoltServerAddress ignoredAddress, RoutingContext ignoredRoutingContext, BoltAgent ignoredBoltAgent, String ignoredUserAgent, int ignoredConnectTimeoutMillis, SecurityPlan securityPlan, AuthToken authToken)
CompletionStage<Boolean>	supportsSessionAuth(BoltServerAddress ignoredAddress, RoutingContext ignoredRoutingContext, BoltAgent ignoredBoltAgent, String ignoredUserAgent, int ignoredConnectTimeoutMillis, SecurityPlan securityPlan, AuthToken authToken)
CompletionStage<Void>	verifyConnectivity(BoltServerAddress ignoredAddress, RoutingContext ignoredRoutingContext, BoltAgent ignoredBoltAgent, String ignoredUserAgent, int ignoredConnectTimeoutMillis, SecurityPlan securityPlan, AuthToken authToken)

Methods inherited from class java.lang.Object

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

Constructor Details

PooledBoltConnectionProvider

public PooledBoltConnectionProvider(BoltConnectionProvider boltConnectionProvider,
 int maxSize,
 long acquisitionTimeout,
 long maxLifetime,
 long idleBeforeTest,
 Clock clock,
 LoggingProvider logging,
 MetricsListener metricsListener,
 BoltServerAddress address,
 RoutingContext routingContext,
 BoltAgent boltAgent,
 String userAgent,
 int connectTimeoutMillis)

Method Details

connect

public CompletionStage<BoltConnection> connect(BoltServerAddress ignoredAddress,
 RoutingContext ignoredRoutingContext,
 BoltAgent ignoredBoltAgent,
 String ignoredUserAgent,
 int ignoredConnectTimeoutMillis,
 SecurityPlan securityPlan,
 DatabaseName databaseName,
 Supplier<CompletionStage<AuthToken>> authTokenStageSupplier,
 AccessMode mode,
 Set<String> bookmarks,
 String impersonatedUser,
 BoltProtocolVersion minVersion,
 NotificationConfig notificationConfig,
 Consumer<DatabaseName> databaseNameConsumer,
 Map<String,Object> additionalParameters)

Specified by:

connect in interface BoltConnectionProvider

verifyConnectivity

public CompletionStage<Void> verifyConnectivity(BoltServerAddress ignoredAddress,
 RoutingContext ignoredRoutingContext,
 BoltAgent ignoredBoltAgent,
 String ignoredUserAgent,
 int ignoredConnectTimeoutMillis,
 SecurityPlan securityPlan,
 AuthToken authToken)

Specified by:

verifyConnectivity in interface BoltConnectionProvider

supportsMultiDb

public CompletionStage<Boolean> supportsMultiDb(BoltServerAddress ignoredAddress,
 RoutingContext ignoredRoutingContext,
 BoltAgent ignoredBoltAgent,
 String ignoredUserAgent,
 int ignoredConnectTimeoutMillis,
 SecurityPlan securityPlan,
 AuthToken authToken)

Specified by:

supportsMultiDb in interface BoltConnectionProvider

supportsSessionAuth

public CompletionStage<Boolean> supportsSessionAuth(BoltServerAddress ignoredAddress,
 RoutingContext ignoredRoutingContext,
 BoltAgent ignoredBoltAgent,
 String ignoredUserAgent,
 int ignoredConnectTimeoutMillis,
 SecurityPlan securityPlan,
 AuthToken authToken)

Specified by:

supportsSessionAuth in interface BoltConnectionProvider

close

public CompletionStage<Void> close()

Specified by:

close in interface BoltConnectionProvider

onExpired

public void onExpired()