Module org.neo4j.driver

Package org.neo4j.driver.internal.async.pool

Class ConnectionPoolImpl

java.lang.Object

org.neo4j.driver.internal.async.pool.ConnectionPoolImpl

All Implemented Interfaces:

ConnectionPool

public class ConnectionPoolImpl
extends Object
implements ConnectionPool

Field Summary

Fields inherited from interface org.neo4j.driver.internal.spi.ConnectionPool

CONNECTION_POOL_CLOSED_ERROR_MESSAGE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConnectionPoolImpl(ChannelConnector connector, io.netty.bootstrap.Bootstrap bootstrap, NettyChannelTracker nettyChannelTracker, PoolSettings settings, MetricsListener metricsListener, Logging logging, Clock clock, boolean ownsEventLoopGroup, ConnectionFactory connectionFactory)
	ConnectionPoolImpl(ChannelConnector connector, io.netty.bootstrap.Bootstrap bootstrap, PoolSettings settings, MetricsListener metricsListener, Logging logging, Clock clock, boolean ownsEventLoopGroup)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Connection>	acquire(org.neo4j.driver.internal.BoltServerAddress address, AuthToken overrideAuthToken)
CompletionStage<Void>	close()
int	inUseConnections(ServerAddress address)
boolean	isOpen(org.neo4j.driver.internal.BoltServerAddress address)
void	retainAll(Set<org.neo4j.driver.internal.BoltServerAddress> addressesToRetain)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionPoolImpl

public ConnectionPoolImpl(ChannelConnector connector,
 io.netty.bootstrap.Bootstrap bootstrap,
 PoolSettings settings,
 MetricsListener metricsListener,
 Logging logging,
 Clock clock,
 boolean ownsEventLoopGroup)

ConnectionPoolImpl

protected ConnectionPoolImpl(ChannelConnector connector,
 io.netty.bootstrap.Bootstrap bootstrap,
 NettyChannelTracker nettyChannelTracker,
 PoolSettings settings,
 MetricsListener metricsListener,
 Logging logging,
 Clock clock,
 boolean ownsEventLoopGroup,
 ConnectionFactory connectionFactory)

Method Details

acquire

public CompletionStage<Connection> acquire(org.neo4j.driver.internal.BoltServerAddress address,
 AuthToken overrideAuthToken)

Specified by:

acquire in interface ConnectionPool

retainAll

public void retainAll(Set<org.neo4j.driver.internal.BoltServerAddress> addressesToRetain)

Specified by:

retainAll in interface ConnectionPool

inUseConnections

public int inUseConnections(ServerAddress address)

Specified by:

inUseConnections in interface ConnectionPool

close

public CompletionStage<Void> close()

Specified by:

close in interface ConnectionPool

isOpen

public boolean isOpen(org.neo4j.driver.internal.BoltServerAddress address)

Specified by:

isOpen in interface ConnectionPool

toString

public String toString()

Overrides:

toString in class Object