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