public class RpcSocketPool
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
RpcSocketPool.ShutdownHandler
Shutdown handler for cleaning up before a socket is closed
|
Constructor and Description |
---|
RpcSocketPool(int poolSize,
java.lang.String host,
int port,
java.util.Properties socketProperties,
RpcSocketPool.ShutdownHandler shutdownHandler)
Create a new socket pool with a max pool size, host, port, and socket
properties, and an optional shutdown handler
|
RpcSocketPool(int poolSize,
java.lang.String host,
int port,
java.util.Properties socketProperties,
RpcSocketPool.ShutdownHandler shutdownHandler,
boolean secure)
Create a new socket pool indicating whether it is secure (SSL) or not.
|
Modifier and Type | Method and Description |
---|---|
java.net.Socket |
acquire()
Acquire a socket to the configured server address
|
void |
disconnect()
Disconnect all sockets from the specified host and port
|
void |
release(java.net.Socket socket,
RpcSocketPool.ShutdownHandler shutdownHandler)
Release a socket back to the pool as no longer using
|
void |
timeout(int idleDuration)
Timeout any sockets idle for greater than or equal to the milliseconds
value specified
|
public RpcSocketPool(int poolSize, java.lang.String host, int port, java.util.Properties socketProperties, RpcSocketPool.ShutdownHandler shutdownHandler, boolean secure)
poolSize
- poolSizehost
- hostport
- portsocketProperties
- socketPropertiesshutdownHandler
- shutdownHandlersecure
- securepublic RpcSocketPool(int poolSize, java.lang.String host, int port, java.util.Properties socketProperties, RpcSocketPool.ShutdownHandler shutdownHandler)
poolSize
- poolSizehost
- hostport
- portsocketProperties
- socketPropertiesshutdownHandler
- shutdownHandlerpublic java.net.Socket acquire() throws java.io.IOException
java.io.IOException
- on errorpublic void release(java.net.Socket socket, RpcSocketPool.ShutdownHandler shutdownHandler) throws java.io.IOException
socket
- socketshutdownHandler
- shutdownHandlerjava.io.IOException
- on errorpublic void disconnect()
public void timeout(int idleDuration)
idleDuration
- idleDuration