Module org.neo4j.bolt.connection.netty

Package org.neo4j.bolt.connection.netty

Class NettyBoltConnectionProvider

java.lang.Object

org.neo4j.bolt.connection.netty.NettyBoltConnectionProvider

All Implemented Interfaces:

BoltConnectionProvider

public final class NettyBoltConnectionProvider
extends Object
implements BoltConnectionProvider

Constructor Summary

Constructors

Constructor	Description
NettyBoltConnectionProvider(io.netty.channel.EventLoopGroup eventLoopGroup, Clock clock, DomainNameResolver domainNameResolver, io.netty.channel.local.LocalAddress localAddress, LoggingProvider logging, ValueFactory valueFactory, MetricsListener metricsListener)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	close()
CompletionStage<BoltConnection>	connect(BoltServerAddress address, RoutingContext routingContext, BoltAgent boltAgent, String userAgent, int connectTimeoutMillis, 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)
CompletionStage<Boolean>	supportsMultiDb(BoltServerAddress address, RoutingContext routingContext, BoltAgent boltAgent, String userAgent, int connectTimeoutMillis, SecurityPlan securityPlan, AuthToken authToken)
CompletionStage<Boolean>	supportsSessionAuth(BoltServerAddress address, RoutingContext routingContext, BoltAgent boltAgent, String userAgent, int connectTimeoutMillis, SecurityPlan securityPlan, AuthToken authToken)
CompletionStage<Void>	verifyConnectivity(BoltServerAddress address, RoutingContext routingContext, BoltAgent boltAgent, String userAgent, int connectTimeoutMillis, SecurityPlan securityPlan, AuthToken authToken)

Methods inherited from class java.lang.Object

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

Constructor Details

NettyBoltConnectionProvider

public NettyBoltConnectionProvider(io.netty.channel.EventLoopGroup eventLoopGroup,
 Clock clock,
 DomainNameResolver domainNameResolver,
 io.netty.channel.local.LocalAddress localAddress,
 LoggingProvider logging,
 ValueFactory valueFactory,
 MetricsListener metricsListener)

Method Details

connect

public CompletionStage<BoltConnection> connect(BoltServerAddress address,
 RoutingContext routingContext,
 BoltAgent boltAgent,
 String userAgent,
 int connectTimeoutMillis,
 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 address,
 RoutingContext routingContext,
 BoltAgent boltAgent,
 String userAgent,
 int connectTimeoutMillis,
 SecurityPlan securityPlan,
 AuthToken authToken)

Specified by:

verifyConnectivity in interface BoltConnectionProvider

supportsMultiDb

public CompletionStage<Boolean> supportsMultiDb(BoltServerAddress address,
 RoutingContext routingContext,
 BoltAgent boltAgent,
 String userAgent,
 int connectTimeoutMillis,
 SecurityPlan securityPlan,
 AuthToken authToken)

Specified by:

supportsMultiDb in interface BoltConnectionProvider

supportsSessionAuth

public CompletionStage<Boolean> supportsSessionAuth(BoltServerAddress address,
 RoutingContext routingContext,
 BoltAgent boltAgent,
 String userAgent,
 int connectTimeoutMillis,
 SecurityPlan securityPlan,
 AuthToken authToken)

Specified by:

supportsSessionAuth in interface BoltConnectionProvider

close

public CompletionStage<Void> close()

Specified by:

close in interface BoltConnectionProvider