public class AuthorityConnectorPool extends Object implements IAuthorityConnectorPool
Modifier and Type | Class and Description |
---|---|
protected static class |
AuthorityConnectorPool.LocalPool
Actual static output connector pool
|
Modifier and Type | Field and Description |
---|---|
static String |
_rcsid |
protected static AuthorityConnectorPool.LocalPool |
localPool
Local connector pool
|
protected IThreadContext |
threadContext
Thread context
|
Constructor and Description |
---|
AuthorityConnectorPool(IThreadContext threadContext)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
closeAllConnectors()
Clean up all open authority connector handles.
|
void |
flushUnusedConnectors()
Flush only those connector handles that are currently unused.
|
IAuthorityConnector |
grab(IAuthorityConnection authorityConnection)
Get an authority connector.
|
IAuthorityConnector[] |
grabMultiple(String[] orderingKeys,
IAuthorityConnection[] authorityConnections)
Get multiple authority connectors, all at once.
|
void |
pollAllConnectors()
Idle notification for inactive authority connector handles.
|
void |
release(IAuthorityConnection connection,
IAuthorityConnector connector)
Release an output connector.
|
void |
releaseMultiple(IAuthorityConnection[] connections,
IAuthorityConnector[] connectors)
Release multiple authority connectors.
|
public static final String _rcsid
protected static final AuthorityConnectorPool.LocalPool localPool
protected final IThreadContext threadContext
public AuthorityConnectorPool(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public IAuthorityConnector[] grabMultiple(String[] orderingKeys, IAuthorityConnection[] authorityConnections) throws ManifoldCFException
grabMultiple
in interface IAuthorityConnectorPool
orderingKeys
- are the keys which determine in what order the connectors are obtained.authorityConnections
- are the connections to use the build the connector instances.ManifoldCFException
public IAuthorityConnector grab(IAuthorityConnection authorityConnection) throws ManifoldCFException
grab
in interface IAuthorityConnectorPool
authorityConnection
- is the authority connection to base the connector instance on.ManifoldCFException
public void releaseMultiple(IAuthorityConnection[] connections, IAuthorityConnector[] connectors) throws ManifoldCFException
releaseMultiple
in interface IAuthorityConnectorPool
connections
- are the connections describing the instances to release.connectors
- are the connector instances to release.ManifoldCFException
public void release(IAuthorityConnection connection, IAuthorityConnector connector) throws ManifoldCFException
release
in interface IAuthorityConnectorPool
connection
- is the connection describing the instance to release.connector
- is the connector to release.ManifoldCFException
public void pollAllConnectors() throws ManifoldCFException
pollAllConnectors
in interface IAuthorityConnectorPool
ManifoldCFException
public void flushUnusedConnectors() throws ManifoldCFException
flushUnusedConnectors
in interface IAuthorityConnectorPool
ManifoldCFException
public void closeAllConnectors() throws ManifoldCFException
closeAllConnectors
in interface IAuthorityConnectorPool
ManifoldCFException