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 and Description
ORemoteConnectionPool(int iMaxResources, boolean createAsyncListener)

Method Summary

Modifier and Type	Method and Description
OChannelBinaryAsynchClient	acquire(String iServerURL, long timeout, OContextConfiguration clientConfiguration, Map<String,Object> iConfiguration, OStorageRemoteAsynchEventListener iListener)
protected OChannelBinaryAsynchClient	createNetworkConnection(String iServerURL, OContextConfiguration clientConfiguration, Map<String,Object> iAdditionalArg)
OChannelBinaryAsynchClient	createNewResource(String iKey, Object... iAdditionalArgs) 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, Object[] iAdditionalArgs, 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 Detail

ORemoteConnectionPool

public ORemoteConnectionPool(int iMaxResources,
                             boolean createAsyncListener)

Method Detail

createNetworkConnection

protected OChannelBinaryAsynchClient createNetworkConnection(String iServerURL,
                                                             OContextConfiguration clientConfiguration,
                                                             Map<String,Object> iAdditionalArg)
                                                      throws OIOException

Throws:

OIOException

createNewResource

public OChannelBinaryAsynchClient createNewResource(String iKey,
                                                    Object... iAdditionalArgs)

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,
                             Object[] iAdditionalArgs,
                             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,
                                          Map<String,Object> iConfiguration,
                                          OStorageRemoteAsynchEventListener iListener)