Modifier and Type | Method and Description |
---|---|
ProcessingContainer |
CPEDeployerDefaultImpl.deployCasProcessor(List aCasProcessorList,
CPMEngine aEngine,
boolean redeploy)
Deploys integrated Cas Processor.
|
Modifier and Type | Method and Description |
---|---|
ProcessingContainer |
SocketCasProcessorDeployer.deployCasProcessor(List aCasProcessorList,
CPMEngine aEngine,
boolean redeploy)
Deploys integrated Cas Processor.
|
Modifier and Type | Method and Description |
---|---|
ProcessingContainer |
VinciCasProcessorDeployer.deployCasProcessor(List aCasProcessorList,
CPMEngine aEngine,
boolean redeploy)
Deploys integrated Cas Processor.
|
Modifier and Type | Field and Description |
---|---|
protected CPMEngine |
NonThreadedProcessingUnit.cpm |
protected CPMEngine |
BoundedWorkQueue.cpm |
protected CPMEngine |
ProcessingUnit.cpm |
Modifier and Type | Method and Description |
---|---|
void |
NonThreadedProcessingUnit.setCPMEngine(CPMEngine acpm)
Alternative method of providing the reference to the component managing the lifecycle of the
CPE
|
void |
ProcessingUnit.setCPMEngine(CPMEngine acpm)
Alternative method of providing the reference to the component managing the lifecycle of the
CPE
|
Constructor and Description |
---|
ArtifactProducer(CPMEngine acpm)
Instantiates and initializes this instance.
|
ArtifactProducer(CPMEngine acpm,
CPECasPool aPool)
Construct instance of this class with a reference to the cpe engine and a pool of cas'es.
|
BoundedWorkQueue(int aQueueSize,
String aQueueName,
CPMEngine aCpmEngine)
Initialize the instance
|
DebugControlThread(CPMEngine aCpm,
String aFilename,
int aCheckpointFrequency) |
NonThreadedProcessingUnit(CPMEngine acpm) |
NonThreadedProcessingUnit(CPMEngine acpm,
BoundedWorkQueue aInputQueue,
BoundedWorkQueue aOutputQueue)
Initialize the PU
|
ProcessingUnit(CPMEngine acpm) |
ProcessingUnit(CPMEngine acpm,
BoundedWorkQueue aInputQueue,
BoundedWorkQueue aOutputQueue)
Initialize the PU
|
SequencedQueue(int aQueueSize,
String aQueueName,
CPMEngine aCpmEngine)
Initialize this queue
|
Constructor and Description |
---|
ExpirationTimer(long aTimeout,
HashMap aMap,
String aKey,
CPMEngine aCpm)
Constructs a Timer that expires after a given interval.
|
Copyright © 2016. All rights reserved.