Module org.neo4j.bolt.connection.netty

Package org.neo4j.bolt.connection.netty.impl

Class NettyConnectionProvider

java.lang.Object

org.neo4j.bolt.connection.netty.impl.NettyConnectionProvider

All Implemented Interfaces:

ConnectionProvider

public final class NettyConnectionProvider
extends Object
implements ConnectionProvider

Constructor Summary

Constructors

Constructor	Description
NettyConnectionProvider(io.netty.channel.EventLoopGroup eventLoopGroup, NettyTransport nettyTransport, Clock clock, DomainNameResolver domainNameResolver, io.netty.channel.local.LocalAddress localAddress, BoltProtocolVersion maxVersion, boolean fastOpen, long preferredCapabilitiesMask, LoggingProvider logging, ValueFactory valueFactory, ObservationProvider observationProvider)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Connection>	acquireConnection(URI uri, SecurityPlan securityPlan, RoutingContext routingContext, Map<String,Value> authMap, BoltAgent boltAgent, String userAgent, int connectTimeoutMillis, long initialisationTimeoutMillis, CompletableFuture<Long> latestAuthMillisFuture, NotificationConfig notificationConfig, ImmutableObservation parentObservation)

Methods inherited from class java.lang.Object

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

Constructor Details

NettyConnectionProvider

public NettyConnectionProvider(io.netty.channel.EventLoopGroup eventLoopGroup,
 NettyTransport nettyTransport,
 Clock clock,
 DomainNameResolver domainNameResolver,
 io.netty.channel.local.LocalAddress localAddress,
 BoltProtocolVersion maxVersion,
 boolean fastOpen,
 long preferredCapabilitiesMask,
 LoggingProvider logging,
 ValueFactory valueFactory,
 ObservationProvider observationProvider)

Method Details

acquireConnection

public CompletionStage<Connection> acquireConnection(URI uri,
 SecurityPlan securityPlan,
 RoutingContext routingContext,
 Map<String,Value> authMap,
 BoltAgent boltAgent,
 String userAgent,
 int connectTimeoutMillis,
 long initialisationTimeoutMillis,
 CompletableFuture<Long> latestAuthMillisFuture,
 NotificationConfig notificationConfig,
 ImmutableObservation parentObservation)

Specified by:

acquireConnection in interface ConnectionProvider