public class TCPConnector extends PooledConnector
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
charset |
protected java.lang.String |
host |
protected int |
port |
protected int |
timeout |
allConnections, askingBusy, askingDedicated, debug, freeList, maxConnections, maxInactivity, maxLifeTime, maxUseCount
cluster, connectorClass, instance, name, properties, refreshInterval, scheduler, sharedConfiguration, url
Constructor and Description |
---|
TCPConnector(java.lang.String url,
java.util.Properties properties)
Creates a new instance of TCPConnector
|
Modifier and Type | Method and Description |
---|---|
protected static boolean |
acceptsURL(java.lang.String URL) |
java.lang.String |
info() |
protected void |
info(java.lang.StringBuilder s) |
protected palio.connectors.PooledConnection |
newConnection(palio.connectors.PooledConnection conn) |
byte[] |
read(byte[] data) |
java.lang.String |
read(java.lang.String data) |
void |
write(byte[] data) |
void |
write(java.lang.String data) |
BusyChecker, clearThreadResources, close, connect, DedicateChecker, FreeChecker, getConnection, getDedicatedConnection, getFreeConnection, getInfo, getIntParam, init, putConnection, reconnect, refresh, setDedicated, unsetDedicated
delete, getAsPalioConnector, getConnector, getConnector, getInstance, getLogConfiguration, getName, getUrl, init, log, logDebug, logError, logError, logWarning, save, scheduler, setDedicatedLogConfiguration, setInstance
protected final java.lang.String host
protected final int port
protected int timeout
protected java.lang.String charset
public TCPConnector(java.lang.String url, java.util.Properties properties)
protected static boolean acceptsURL(java.lang.String URL)
protected palio.connectors.PooledConnection newConnection(palio.connectors.PooledConnection conn) throws PalioException
newConnection
in class PooledConnector
PalioException
public void write(byte[] data) throws PalioException, java.io.UnsupportedEncodingException
PalioException
java.io.UnsupportedEncodingException
public void write(java.lang.String data) throws PalioException, java.io.UnsupportedEncodingException
PalioException
java.io.UnsupportedEncodingException
public byte[] read(byte[] data) throws PalioException, java.io.UnsupportedEncodingException
PalioException
java.io.UnsupportedEncodingException
public java.lang.String read(java.lang.String data) throws PalioException, java.io.UnsupportedEncodingException
PalioException
java.io.UnsupportedEncodingException
public java.lang.String info()
info
in class PooledConnector
protected void info(java.lang.StringBuilder s)
info
in class PooledConnector