Skip navigation links

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 java.lang.Object

implements ConnectionPool<TConnection>

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

Constructor Summary

BlockingQueueConnectionPool()

Method Summary

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 Detail

BlockingQueueConnectionPool

public BlockingQueueConnectionPool()

Method Detail

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

Skip navigation links