Class SocketCasProcessorDeployer
java.lang.Object
org.apache.uima.collection.impl.cpm.container.deployer.socket.SocketCasProcessorDeployer
- All Implemented Interfaces:
CasProcessorDeployer
Reference implementation of the
CasProcessorDeployer
component responsible for launch and
termination of the fenced CasProcessor. It uses a plug-in ProcessControllerAdapter
object
to delegate launch requests from the CPM to the external application.-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate ProcessControllerAdapter
The controller.private CPEFactory
The cpe factory.private URL[]
The service urls. -
Constructor Summary
ConstructorsConstructorDescriptionSocketCasProcessorDeployer
(ProcessControllerAdapter aController) Instantiates a new socket cas processor deployer.SocketCasProcessorDeployer
(ProcessControllerAdapter aController, CPEFactory aCpeFactory) Instantiates a new socket cas processor deployer. -
Method Summary
Modifier and TypeMethodDescriptiondeployCasProcessor
(List aCasProcessorList, boolean redeploy) Uses ProcessControllerAdapter instance to launch fenced CasProcessor.deployCasProcessor
(List aCasProcessorList, CPMEngine aEngine, boolean redeploy) Deploys integrated Cas Processor.void
deployCasProcessor
(ProcessingContainer aProcessingContainer) Uses ProcessControllerAdapter instance to launch fenced CasProcessor.void
undeploy()
void
-
Field Details
-
cpeFactory
The cpe factory. -
serviceUrls
The service urls. -
controller
The controller.
-
-
Constructor Details
-
SocketCasProcessorDeployer
Instantiates a new socket cas processor deployer.- Parameters:
aController
- the a controlleraCpeFactory
- the a cpe factory
-
SocketCasProcessorDeployer
Instantiates a new socket cas processor deployer.- Parameters:
aController
- the a controller
-
-
Method Details
-
deployCasProcessor
public ProcessingContainer deployCasProcessor(List aCasProcessorList, CPMEngine aEngine, boolean redeploy) throws ResourceConfigurationException Deploys integrated Cas Processor. Number of instances this routine actually deploys depends on number of processing threads defined in the CPE descriptor. There is one instance per processing thread created here. The aCasProcessorList contains instantiated Cas Processors. These are instantiated by the CPEFactory.- Parameters:
aCasProcessorList
- - list containing instantiated Cas ProcessorsaEngine
- the a engineredeploy
- - true when redeploying failed Cas Processor- Returns:
- - ProcessingContainer containing pool of CasProcessors
- Throws:
ResourceConfigurationException
- the resource configuration exception
-
deployCasProcessor
public ProcessingContainer deployCasProcessor(List aCasProcessorList, boolean redeploy) throws ResourceConfigurationException Uses ProcessControllerAdapter instance to launch fenced CasProcessor.- Specified by:
deployCasProcessor
in interfaceCasProcessorDeployer
- Parameters:
aCasProcessorList
- the a cas processor listredeploy
- the redeploy- Returns:
- the processing container
- Throws:
ResourceConfigurationException
- the resource configuration exception
-
deployCasProcessor
public void deployCasProcessor(ProcessingContainer aProcessingContainer) throws ResourceConfigurationException Uses ProcessControllerAdapter instance to launch fenced CasProcessor.- Specified by:
deployCasProcessor
in interfaceCasProcessorDeployer
- Parameters:
aProcessingContainer
- the a processing container- Throws:
ResourceConfigurationException
- the resource configuration exception
-
undeploy
- Specified by:
undeploy
in interfaceCasProcessorDeployer
- Throws:
CasProcessorDeploymentException
-
undeploy
- Specified by:
undeploy
in interfaceCasProcessorDeployer
- Throws:
CasProcessorDeploymentException
-