Package | Description |
---|---|
com.ibasco.agql.core.transport.pool | |
com.ibasco.agql.core.util |
Modifier and Type | Field and Description |
---|---|
static ChannelHealthChecker |
ChannelHealthChecker.ACTIVE
|
Modifier and Type | Method and Description |
---|---|
ChannelHealthChecker |
NettyChannelPoolFactory.getChannelHealthChecker()
Getter for the field
channelHealthChecker . |
protected ChannelHealthChecker |
SimpleNettyChannelPool.getChannelHealthChecker()
Returns the
ChannelHealthChecker that will be used to check if a Channel is healthy. |
Constructor and Description |
---|
FixedNettyChannelPool(NettyChannelFactory channelFactory,
io.netty.channel.pool.ChannelPoolHandler handler,
ChannelHealthChecker healthCheck,
FixedNettyChannelPool.AcquireTimeoutAction action,
long acquireTimeoutMillis,
int maxConnections,
int maxPendingAcquires)
Creates a new instance.
|
FixedNettyChannelPool(NettyChannelFactory channelFactory,
io.netty.channel.pool.ChannelPoolHandler handler,
ChannelHealthChecker healthCheck,
FixedNettyChannelPool.AcquireTimeoutAction action,
long acquireTimeoutMillis,
int maxConnections,
int maxPendingAcquires,
boolean releaseHealthCheck,
boolean lastRecentUsed,
NettyChannelPool.ReleaseStrategy releaseStrategy)
Creates a new instance.
|
FixedNettyChannelPool(NettyChannelFactory channelFactory,
io.netty.channel.pool.ChannelPoolHandler handler,
ChannelHealthChecker healthCheck,
FixedNettyChannelPool.AcquireTimeoutAction action,
long acquireTimeoutMillis,
int maxConnections,
int maxPendingAcquires,
boolean releaseHealthCheck,
NettyChannelPool.ReleaseStrategy releaseStrategy)
Creates a new instance.
|
SimpleNettyChannelPool(NettyChannelFactory channelFactory,
io.netty.channel.pool.ChannelPoolHandler handler,
ChannelHealthChecker healthCheck)
Creates a new instance.
|
SimpleNettyChannelPool(NettyChannelFactory channelFactory,
io.netty.channel.pool.ChannelPoolHandler handler,
ChannelHealthChecker healthCheck,
boolean releaseHealthCheck,
boolean lastRecentUsed,
NettyChannelPool.ReleaseStrategy releaseStrategy)
Creates a new instance.
|
SimpleNettyChannelPool(NettyChannelFactory channelFactory,
io.netty.channel.pool.ChannelPoolHandler handler,
ChannelHealthChecker healthCheck,
boolean releaseHealthCheck,
NettyChannelPool.ReleaseStrategy releaseStrategy)
Creates a new instance.
|
Modifier and Type | Field and Description |
---|---|
static Option<ChannelHealthChecker> |
GeneralOptions.POOL_CHANNEL_HEALTH_CHECKER
The
ChannelHealthChecker that is used by the ChannelPool implementation to check if the Channel can be acquired. |
Copyright © 2016–2024. All rights reserved.