Package com.orientechnologies.orient.client.remote

Class ORemoteConnectionPool

java.lang.Object

com.orientechnologies.orient.client.remote.ORemoteConnectionPool

All Implemented Interfaces:

OResourcePoolListener<String,OChannelBinaryAsynchClient>

public class ORemoteConnectionPool
extends Object
implements OResourcePoolListener<String,OChannelBinaryAsynchClient>

Created by tglman on 01/10/15.

Constructor Summary

Constructors

Constructor	Description
ORemoteConnectionPool(int iMaxResources, String host, int port, OContextConfiguration conf)

Method Summary

Modifier and Type	Method	Description
OChannelBinaryAsynchClient	acquire(String iServerURL, long timeout, OContextConfiguration clientConfiguration)
void	checkIdle(long timeout)
protected OChannelBinaryAsynchClient	createNetworkConnection()
OChannelBinaryAsynchClient	createNewResource(String iKey)	Creates a new resource to be used and to be pooled when the client finishes with it.
OResourcePool<String,OChannelBinaryAsynchClient>	getPool()
boolean	reuseResource(String iKey, OChannelBinaryAsynchClient iValue)	Reuses the pooled resource.

Methods inherited from class java.lang.Object

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

Constructor Details

ORemoteConnectionPool

public ORemoteConnectionPool(int iMaxResources,
 String host,
 int port,
 OContextConfiguration conf)

Method Details

createNetworkConnection

protected OChannelBinaryAsynchClient createNetworkConnection()
                                                      throws OIOException

Throws:

OIOException

createNewResource

public OChannelBinaryAsynchClient createNewResource(String iKey)

Description copied from interface: OResourcePoolListener

Creates a new resource to be used and to be pooled when the client finishes with it.

Specified by:

createNewResource in interface OResourcePoolListener<String,OChannelBinaryAsynchClient>

Returns:

The new resource

reuseResource

public boolean reuseResource(String iKey,
 OChannelBinaryAsynchClient iValue)

Description copied from interface: OResourcePoolListener

Reuses the pooled resource.

Specified by:

reuseResource in interface OResourcePoolListener<String,OChannelBinaryAsynchClient>

Returns:

true if can be reused, otherwise false. In this case the resource will be removed from the pool

getPool

public OResourcePool<String,OChannelBinaryAsynchClient> getPool()

acquire

public OChannelBinaryAsynchClient acquire(String iServerURL,
 long timeout,
 OContextConfiguration clientConfiguration)

checkIdle

public void checkIdle(long timeout)