Package | Description |
---|---|
org.glassfish.grizzly.connectionpool |
Modifier and Type | Class and Description |
---|---|
class |
EndpointKey<E>
Simple
Endpoint implementation. |
Modifier and Type | Field and Description |
---|---|
protected Endpoint<E> |
SingleEndpointPool.Builder.endpoint
The endpoint information
|
Modifier and Type | Field and Description |
---|---|
protected Map<Endpoint<E>,SingleEndpointPool<E>> |
MultiEndpointPool.endpointToPoolMap
Maps endpoint -to- SingleEndpointPool
|
Modifier and Type | Method and Description |
---|---|
static <E> Endpoint<E> |
Endpoint.Factory.create(E targetAddress,
ConnectorHandler<E> connectorHandler) |
static <E> Endpoint<E> |
Endpoint.Factory.create(E targetAddress,
E localAddress,
ConnectorHandler<E> connectorHandler) |
static <E> Endpoint<E> |
Endpoint.Factory.create(Object id,
E targetAddress,
E localAddress,
ConnectorHandler<E> connectorHandler) |
Endpoint<E> |
SingleEndpointPool.getEndpoint() |
Modifier and Type | Method and Description |
---|---|
boolean |
MultiEndpointPool.attach(Endpoint<E> endpoint,
Connection connection)
Attaches "foreign"
Connection to the pool. |
SingleEndpointPool<E> |
MultiEndpointPool.EndpointPoolBuilder.build0(Endpoint<E> e) |
protected SingleEndpointPool<E> |
SingleEndpointPool.Builder.build0(Endpoint<E> e) |
void |
MultiEndpointPool.close(Endpoint<E> endpoint)
Closes specific endpoint associated pool and releases its resources.
|
protected SingleEndpointPool<E> |
MultiEndpointPool.createSingleEndpointPool(Endpoint<E> endpoint)
Creates
SingleEndpointPool instance. |
void |
MultiEndpointPool.EndpointPoolCustomizer.customize(Endpoint<E> endpoint,
MultiEndpointPool.EndpointPoolBuilder<E> builder) |
SingleEndpointPool.Builder<E> |
SingleEndpointPool.Builder.endpoint(Endpoint<E> endpoint)
Sets the endpoint information.
|
protected SingleEndpointPool<E> |
MultiEndpointPool.obtainSingleEndpointPool(Endpoint<E> endpoint)
Obtains
SingleEndpointPool associated with the specific endpoint
represented by Endpoint . |
Connection |
MultiEndpointPool.poll(Endpoint<E> endpoint) |
GrizzlyFuture<Connection> |
MultiEndpointPool.take(Endpoint<E> endpoint)
Obtains a
Connection to the specified endpoint from the pool in
non-blocking/asynchronous fashion. |
void |
MultiEndpointPool.take(Endpoint<E> endpoint,
CompletionHandler<Connection> completionHandler)
Obtains a
Connection to the specified endpoint from the pool
in non-blocking/asynchronous fashion. |
Constructor and Description |
---|
Builder(Endpoint<E> endpoint,
ConnectorHandler<E> connectorHandler,
E endpointAddress,
E localEndpointAddress,
int corePoolSize,
int maxPoolSize,
DelayedExecutor delayedExecutor,
long connectTimeoutMillis,
long reconnectDelayMillis,
int maxReconnectAttempts,
long asyncPollTimeoutMillis,
long connectionTTLMillis,
boolean failFastWhenMaxSizeReached,
long keepAliveTimeoutMillis,
long keepAliveCheckIntervalMillis) |
SingleEndpointPool(Endpoint<E> endpoint,
int corePoolSize,
int maxPoolSize,
DelayedExecutor.DelayQueue<SingleEndpointPool.ConnectTimeoutTask> connectTimeoutQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.ReconnectTask> reconnectQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.KeepAliveCleanerTask> keepAliveCleanerQueue,
DelayedExecutor.DelayQueue<Link<SingleEndpointPool.AsyncPoll>> asyncPollTimeoutQueue,
DelayedExecutor.DelayQueue<ConnectionInfo> connectionTTLQueue,
long connectTimeoutMillis,
long keepAliveTimeoutMillis,
long keepAliveCheckIntervalMillis,
long reconnectDelayMillis,
int maxReconnectAttempts,
long asyncPollTimeoutMillis,
long connectionTTLMillis,
boolean failFastWhenMaxSizeReached)
Constructs SingleEndpointPool instance.
|
SingleEndpointPool(Endpoint<E> endpoint,
int corePoolSize,
int maxPoolSize,
DelayedExecutor delayedExecutor,
long connectTimeoutMillis,
long keepAliveTimeoutMillis,
long keepAliveCheckIntervalMillis,
long reconnectDelayMillis,
int maxReconnectAttempts,
long asyncPollTimeoutMillis,
long connectionTTLMillis,
boolean failFastWhenMaxSizeReached)
Constructs SingleEndpointPool instance.
|
Copyright © 2021 Oracle Corporation. All rights reserved.