Package oracle.stellent.ridc.protocol.impl

Class BlockingQueueConnectionPool<TConnection extends Connection>

java.lang.Object

oracle.stellent.ridc.protocol.impl.BlockingQueueConnectionPool<TConnection>

All Implemented Interfaces:

ConnectionPool<TConnection>

public class BlockingQueueConnectionPool<TConnection extends Connection>
extends Object
implements ConnectionPool<TConnection>

Threading model that uses a BlockingQueue to handle multiple Content Server connections.

Constructor Summary

Constructors

Constructor	Description
BlockingQueueConnectionPool()

Method Summary

Modifier and Type	Method	Description
TConnection	acquireConnection()	Obtain a connection from the pool for the current thread
void	initialize(IdcClientConfig clientConfig, ConnectionManager<TConnection,IdcClientConfig> connectionManager)	Initialize the threading model
void	releaseConnection(TConnection connection)	Release the connection for this thread

Methods inherited from class java.lang.Object

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

Constructor Details

BlockingQueueConnectionPool

public BlockingQueueConnectionPool()

Method Details

initialize

public void initialize(IdcClientConfig clientConfig,
 ConnectionManager<TConnection,IdcClientConfig> connectionManager)
                throws ProtocolException

Initialize the threading model

Specified by:

initialize in interface ConnectionPool<TConnection extends Connection>

Parameters:

clientConfig - the client configuration

connectionManager - the connection manager

Throws:

ProtocolException

acquireConnection

public TConnection acquireConnection()
                              throws ProtocolException

Description copied from interface: ConnectionPool

Obtain a connection from the pool for the current thread

Specified by:

acquireConnection in interface ConnectionPool<TConnection extends Connection>

Returns:

a new connection for the current thread

Throws:

ProtocolException

releaseConnection

public void releaseConnection(TConnection connection)

Release the connection for this thread

Specified by:

releaseConnection in interface ConnectionPool<TConnection extends Connection>

Parameters:

connection - the connection