|
| |
|
| java.lang.Object
 org.jboss.invocation.pooled.interfaces.PooledInvokerProxy
| PooledInvokerProxy | | public class PooledInvokerProxy implements Invoker,Externalizable(Code) | | Client socket connections are pooled to avoid the overhead of
making a connection. RMI seems to do a new connection with each
request.
author:
Bill Burke
author:
Scott.Stark@jboss.org
version:
$Revision: 60313 $ |
| MAX_RETRIES | | public static int MAX_RETRIES(Code) | | Set number of retries in getSocket method
|
| connectionPools | | final protected static Map connectionPools(Code) | | A class wide pool Map>
|
| deserializeTime | | public static long deserializeTime(Code) | | |
| getSocketTime | | public static long getSocketTime(Code) | | |
| maxPoolSize | | protected int maxPoolSize(Code) | | |
| pool | | protected LinkedList pool(Code) | | Pool for this invoker. This is shared between all
instances of proxies attached to a specific invoker
This should not be serializable, but is for backward compatibility.
|
| readTime | | public static long readTime(Code) | | |
| retryCount | | protected int retryCount(Code) | | The number of times to retry after seeing a ConnectionException
|
| serializeTime | | public static long serializeTime(Code) | | |
| tpcFactory | | protected static TransactionPropagationContextFactory tpcFactory(Code) | | Factory for transaction propagation contexts.
|
| usedPooled | | public static long usedPooled(Code) | | The number of times a connection has been obtained from a pool
|
| writeTime | | public static long writeTime(Code) | | |
| PooledInvokerProxy | | public PooledInvokerProxy()(Code) | | Exposed for externalization.
|
| PooledInvokerProxy | | public PooledInvokerProxy(ServerAddress sa, int maxPoolSize)(Code) | | Create a new Proxy.
|
| PooledInvokerProxy | | public PooledInvokerProxy(ServerAddress sa, int maxPoolSize, int retryCount)(Code) | | |
| clearPool | | public static void clearPool(ServerAddress sa)(Code) | | Close all sockets in a specific pool.
|
| clearPools | | public static void clearPools()(Code) | | Close all sockets in all pools
|
| clearStats | | public static void clearStats()(Code) | | Clear all class level stats
|
| firstConnection | | protected ClientSocket firstConnection()(Code) | | |
| getInUseCount | | public static long getInUseCount()(Code) | | the active number of client connections |
| getPoolCount | | public long getPoolCount()(Code) | | the proxy local pool count |
| getPooledConnection | | protected ClientSocket getPooledConnection()(Code) | | |
| getSocketCloseCount | | public static long getSocketCloseCount()(Code) | | |
| getSocketConnectCount | | public static long getSocketConnectCount()(Code) | | |
| getTotalPoolCount | | public static int getTotalPoolCount()(Code) | | the total number of pooled connections across all ServerAddresses |
| getTransactionPropagationContext | | public Object getTransactionPropagationContext() throws SystemException(Code) | | ???
the transaction propagation context of the transactionassociated with the current thread.Returns null if the transaction manager was neverset, or if no transaction is associated with the current thread. |
| getUsedPooled | | public static long getUsedPooled()(Code) | | the number of times a connection was returned from a pool |
| initPool | | protected void initPool()(Code) | | |
| invoke | | public Object invoke(Invocation invocation) throws Exception(Code) | | The invocation on the delegate, calls the right invoker. Remote if we are remote,
local if we are local.
|
| returnConnection | | protected boolean returnConnection(ClientSocket socket)(Code) | | Return a socket to the pool
Parameters:
socket - true if socket was added to the pool, false if the poolwas full |
| setTPCFactory | | public static void setTPCFactory(TransactionPropagationContextFactory tpcf)(Code) | | |
|
|
|