Package | Description |
---|---|
com.ibasco.agql.core.transport.pool | |
com.ibasco.agql.core.util |
Modifier and Type | Method and Description |
---|---|
static FixedNettyChannelPool.AcquireTimeoutAction |
FixedNettyChannelPool.AcquireTimeoutAction.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FixedNettyChannelPool.AcquireTimeoutAction[] |
FixedNettyChannelPool.AcquireTimeoutAction.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
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.
|
Modifier and Type | Field and Description |
---|---|
static Option<FixedNettyChannelPool.AcquireTimeoutAction> |
GeneralOptions.POOL_ACQUIRE_TIMEOUT_ACTION
The action that will be executed once an acquire timeout is thrown
|
Copyright © 2016–2024. All rights reserved.