com.gigaspaces.proxy_pool

Class SpaceProxyPool

java.lang.Object

com.gigaspaces.proxy_pool.SpaceProxyPool

public class SpaceProxyPool
extends Object

Since:

16.0.

Author:

Meshi Ruff

Constructor Summary

Constructors

Constructor and Description
SpaceProxyPool(int capacity, long expirationTime, long waitingTimeout, SpaceProxyPoolFactory spaceProxyPoolFactory) Constructor for tests.
SpaceProxyPool(SpaceProxyPoolFactory spaceProxyPoolFactory)

Method Summary

Modifier and Type	Method and Description
void	deleteLoggedOutSession(String sessionId) When a session is logged out, remove all connections of this session
void	evict() Evict the connections which pass the expiration time.
long	getExpirationTime()
int	getHashMapSize()
GConnection	getOrCreate(IJSpace ijSpace, String sessionId, Properties props) Get connection for specific sessionId.
int	getProxyCounter()
boolean	isSessionIdExists(String sessionId)
void	putBack(GConnection gConnection, String sessionId, String spaceName) Put back the connection after usage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SpaceProxyPool

public SpaceProxyPool(SpaceProxyPoolFactory spaceProxyPoolFactory)

SpaceProxyPool

public SpaceProxyPool(int capacity,
                      long expirationTime,
                      long waitingTimeout,
                      SpaceProxyPoolFactory spaceProxyPoolFactory)

Constructor for tests.

Method Detail

getOrCreate

public GConnection getOrCreate(IJSpace ijSpace,
                               String sessionId,
                               Properties props)
                        throws SQLException,
                               TimeoutException,
                               SpaceProxyPoolException,
                               InterruptedException

Get connection for specific sessionId. If sessionId does not exist, create new connection

Parameters:

ijSpace -

sessionId -

props -

Returns:

gConnection

Throws:

SQLException

TimeoutException - if timeout reached while waiting for connection

SpaceProxyPoolException - if the session expired while getting the connection

InterruptedException

putBack

public void putBack(GConnection gConnection,
                    String sessionId,
                    String spaceName)
             throws SpaceProxyPoolException

Put back the connection after usage

Parameters:

gConnection -

sessionId -

spaceName -

Throws:

SpaceProxyPoolException - if the session expired while getting the connection

evict

public void evict()
           throws SQLException

Evict the connections which pass the expiration time. Runs periodically

Throws:

SQLException

deleteLoggedOutSession

public void deleteLoggedOutSession(String sessionId)

When a session is logged out, remove all connections of this session

Parameters:

sessionId -

getExpirationTime

public long getExpirationTime()

getProxyCounter

public int getProxyCounter()

isSessionIdExists

public boolean isSessionIdExists(String sessionId)

getHashMapSize

public int getHashMapSize()