public abstract class PooledConnector extends Connector
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.atomic.AtomicInteger |
allConnections |
protected java.util.concurrent.atomic.AtomicInteger |
askingBusy |
protected java.util.concurrent.atomic.AtomicInteger |
askingDedicated |
protected boolean |
debug |
protected java.util.ArrayList<palio.connectors.PooledConnection> |
freeList |
protected int |
maxConnections |
protected long |
maxInactivity |
protected long |
maxLifeTime |
protected int |
maxUseCount |
cluster, connectorClass, instance, name, properties, refreshInterval, scheduler, sharedConfiguration, url
Constructor and Description |
---|
PooledConnector(java.lang.String url,
java.util.Properties properties) |
Modifier and Type | Method and Description |
---|---|
void |
BusyChecker() |
void |
clearThreadResources() |
void |
close() |
protected palio.connectors.PooledConnection |
connect() |
void |
DedicateChecker() |
void |
FreeChecker() |
protected palio.connectors.PooledConnection |
getConnection() |
protected palio.connectors.PooledConnection |
getDedicatedConnection() |
protected palio.connectors.PooledConnection |
getFreeConnection() |
java.lang.Object[] |
getInfo() |
protected int |
getIntParam(java.lang.String param,
int defaultValue) |
java.lang.String |
info() |
protected void |
info(java.lang.StringBuilder s) |
void |
init() |
protected abstract palio.connectors.PooledConnection |
newConnection(palio.connectors.PooledConnection conn) |
protected void |
putConnection(palio.connectors.PooledConnection connection) |
protected palio.connectors.PooledConnection |
reconnect(palio.connectors.PooledConnection connection,
java.lang.Throwable ex) |
void |
refresh() |
protected void |
setDedicated(java.lang.String log) |
protected void |
unsetDedicated(java.lang.String log) |
delete, getAsPalioConnector, getConnector, getConnector, getInstance, getLogConfiguration, getName, getUrl, init, log, logDebug, logError, logError, logWarning, save, scheduler, setDedicatedLogConfiguration, setInstance
protected final java.util.ArrayList<palio.connectors.PooledConnection> freeList
protected int maxConnections
protected long maxInactivity
protected long maxLifeTime
protected int maxUseCount
protected java.util.concurrent.atomic.AtomicInteger allConnections
protected java.util.concurrent.atomic.AtomicInteger askingBusy
protected java.util.concurrent.atomic.AtomicInteger askingDedicated
protected boolean debug
public PooledConnector(java.lang.String url, java.util.Properties properties)
protected int getIntParam(java.lang.String param, int defaultValue)
public void init() throws PalioException
init
in class Connector
PalioException
protected abstract palio.connectors.PooledConnection newConnection(palio.connectors.PooledConnection conn) throws java.lang.Exception
java.lang.Exception
protected final palio.connectors.PooledConnection reconnect(palio.connectors.PooledConnection connection, java.lang.Throwable ex) throws PalioException
PalioException
protected final palio.connectors.PooledConnection connect() throws PalioException
PalioException
protected final palio.connectors.PooledConnection getConnection() throws PalioException
PalioException
protected final palio.connectors.PooledConnection getFreeConnection() throws PalioException
PalioException
protected final palio.connectors.PooledConnection getDedicatedConnection()
protected final void putConnection(palio.connectors.PooledConnection connection)
protected final void setDedicated(java.lang.String log) throws PalioException
PalioException
protected final void unsetDedicated(java.lang.String log)
public void DedicateChecker()
public void BusyChecker()
public void FreeChecker() throws PalioException
PalioException
public final void clearThreadResources()