Module org.neo4j.bolt.connection.routed

Package org.neo4j.bolt.connection.routed

Class RoutedBoltConnectionSource

java.lang.Object

org.neo4j.bolt.connection.routed.RoutedBoltConnectionSource

All Implemented Interfaces:

BoltConnectionSource<RoutedBoltConnectionParameters>

public class RoutedBoltConnectionSource
extends Object
implements BoltConnectionSource<RoutedBoltConnectionParameters>

A routed BoltConnectionSource implementation that implements Neo4j client-side routing that is typically expected from the neo4j URI schemes.

Since:

4.0.0

Constructor Summary

Constructors

Constructor

Description

RoutedBoltConnectionSource(BoltConnectionSourceFactory boltConnectionSourceFactory, Function<BoltServerAddress,Set<BoltServerAddress>> resolver, DomainNameResolver domainNameResolver, long routingTablePurgeDelayMs, Rediscovery rediscovery, Clock clock, LoggingProvider logging, URI uri, long acquisitionTimeout, List<Class<? extends Throwable>> discoveryAbortingErrors, ObservationProvider observationProvider)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	close()
void	decrementInUseCount(BoltServerAddress address)
CompletionStage<BoltConnection>	getConnection()
CompletionStage<BoltConnection>	getConnection(RoutedBoltConnectionParameters parameters)
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

RoutedBoltConnectionSource

public RoutedBoltConnectionSource(BoltConnectionSourceFactory boltConnectionSourceFactory,
 Function<BoltServerAddress,Set<BoltServerAddress>> resolver,
 DomainNameResolver domainNameResolver,
 long routingTablePurgeDelayMs,
 Rediscovery rediscovery,
 Clock clock,
 LoggingProvider logging,
 URI uri,
 long acquisitionTimeout,
 List<Class<? extends Throwable>> discoveryAbortingErrors,
 ObservationProvider observationProvider)

Method Details

getConnection

public CompletionStage<BoltConnection> getConnection()

Specified by:

getConnection in interface BoltConnectionSource<RoutedBoltConnectionParameters>

getConnection

public CompletionStage<BoltConnection> getConnection(RoutedBoltConnectionParameters parameters)

Specified by:

getConnection in interface BoltConnectionSource<RoutedBoltConnectionParameters>

verifyConnectivity

public CompletionStage<Void> verifyConnectivity()

Specified by:

verifyConnectivity in interface BoltConnectionSource<RoutedBoltConnectionParameters>

supportsMultiDb

public CompletionStage<Boolean> supportsMultiDb()

Specified by:

supportsMultiDb in interface BoltConnectionSource<RoutedBoltConnectionParameters>

supportsSessionAuth

public CompletionStage<Boolean> supportsSessionAuth()

Specified by:

supportsSessionAuth in interface BoltConnectionSource<RoutedBoltConnectionParameters>

decrementInUseCount

public void decrementInUseCount(BoltServerAddress address)

close

public CompletionStage<Void> close()

Specified by:

close in interface BoltConnectionSource<RoutedBoltConnectionParameters>