org.apache.uima.collection.impl.cpm.container.deployer
Class CPEDeployerDefaultImpl

java.lang.Object
  extended by org.apache.uima.collection.impl.cpm.container.deployer.CPEDeployerDefaultImpl
All Implemented Interfaces:
CasProcessorDeployer

public class CPEDeployerDefaultImpl
extends java.lang.Object
implements CasProcessorDeployer

Implements CasProcessorDeployer. Used to instantiate integrated Cas Processor.


Constructor Summary
CPEDeployerDefaultImpl(CPEFactory aCpeFactory)
          Initializes this instance with a reference to the CPE configuration
 
Method Summary
 ProcessingContainer deployCasProcessor(java.util.List aCasProcessorList, boolean redeploy)
          Deploys integrated Cas Processor.
 ProcessingContainer deployCasProcessor(java.util.List aCasProcessorList, CPMEngine aEngine, boolean redeploy)
          Deploys integrated Cas Processor.
 void deployCasProcessor(ProcessingContainer aProcessingContainer)
          Deploys integrated Cas Processor using configuration available in a given Container.
 void undeploy()
           
 void undeploy(java.net.URL aURL)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CPEDeployerDefaultImpl

public CPEDeployerDefaultImpl(CPEFactory aCpeFactory)
Initializes this instance with a reference to the CPE configuration

Parameters:
aCpeFactory - - reference to CPE configuration
Method Detail

deployCasProcessor

public ProcessingContainer deployCasProcessor(java.util.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 Processors
Returns:
- ProcessingContainer containing pool of CasProcessors
Throws:
ResourceConfigurationException

deployCasProcessor

public ProcessingContainer deployCasProcessor(java.util.List aCasProcessorList,
                                              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.

Specified by:
deployCasProcessor in interface CasProcessorDeployer
Parameters:
- - aCasProcessorList - list containing instantiated Cas Processors
Returns:
- ProcessingContainer containing pool of CasProcessors
Throws:
ResourceConfigurationException - - failed to deploy Cas Processor

deployCasProcessor

public void deployCasProcessor(ProcessingContainer aProcessingContainer)
                        throws ResourceConfigurationException
Deploys integrated Cas Processor using configuration available in a given Container. This routine is called when the CasProcessor fails and needs to be restarted.

Specified by:
deployCasProcessor in interface CasProcessorDeployer
Parameters:
aProcessingContainer - - container managing Cas Processor
Throws:
ResourceConfigurationException - - failed to deploy Cas Processor

undeploy

public void undeploy()
              throws CasProcessorDeploymentException
Specified by:
undeploy in interface CasProcessorDeployer
Throws:
CasProcessorDeploymentException

undeploy

public void undeploy(java.net.URL aURL)
              throws CasProcessorDeploymentException
Specified by:
undeploy in interface CasProcessorDeployer
Throws:
CasProcessorDeploymentException


Copyright © 2013. All Rights Reserved.