Module org.neo4j.driver

Package org.neo4j.driver.internal.cluster

Class RoutingTableHandlerImpl

java.lang.Object

org.neo4j.driver.internal.cluster.RoutingTableHandlerImpl

All Implemented Interfaces:

RoutingTableHandler, org.neo4j.driver.internal.RoutingErrorHandler

public class RoutingTableHandlerImpl
extends Object
implements RoutingTableHandler

Constructor Summary

Constructors

Constructor	Description
RoutingTableHandlerImpl(RoutingTable routingTable, Rediscovery rediscovery, ConnectionPool connectionPool, RoutingTableRegistry routingTableRegistry, Logging logging, long routingTablePurgeDelayMs)

Method Summary

Modifier and Type	Method	Description
CompletionStage<RoutingTable>	ensureRoutingTable(ConnectionContext context)
boolean	isRoutingTableAged()
void	onConnectionFailure(org.neo4j.driver.internal.BoltServerAddress address)
void	onWriteFailure(org.neo4j.driver.internal.BoltServerAddress address)
RoutingTable	routingTable()
Set<org.neo4j.driver.internal.BoltServerAddress>	servers()
CompletionStage<RoutingTable>	updateRoutingTable(ClusterCompositionLookupResult compositionLookupResult)

Methods inherited from class java.lang.Object

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

Constructor Details

RoutingTableHandlerImpl

public RoutingTableHandlerImpl(RoutingTable routingTable,
 Rediscovery rediscovery,
 ConnectionPool connectionPool,
 RoutingTableRegistry routingTableRegistry,
 Logging logging,
 long routingTablePurgeDelayMs)

Method Details

onConnectionFailure

public void onConnectionFailure(org.neo4j.driver.internal.BoltServerAddress address)

Specified by:

onConnectionFailure in interface org.neo4j.driver.internal.RoutingErrorHandler

onWriteFailure

public void onWriteFailure(org.neo4j.driver.internal.BoltServerAddress address)

Specified by:

onWriteFailure in interface org.neo4j.driver.internal.RoutingErrorHandler

ensureRoutingTable

public CompletionStage<RoutingTable> ensureRoutingTable(ConnectionContext context)

Specified by:

ensureRoutingTable in interface RoutingTableHandler

updateRoutingTable

public CompletionStage<RoutingTable> updateRoutingTable(ClusterCompositionLookupResult compositionLookupResult)

Specified by:

updateRoutingTable in interface RoutingTableHandler

servers

public Set<org.neo4j.driver.internal.BoltServerAddress> servers()

Specified by:

servers in interface RoutingTableHandler

isRoutingTableAged

public boolean isRoutingTableAged()

Specified by:

isRoutingTableAged in interface RoutingTableHandler

routingTable

public RoutingTable routingTable()

Specified by:

routingTable in interface RoutingTableHandler