org.apache.uima.collection.impl.cpm.container
Class ProcessingContainer_Impl

java.lang.Object
  extended by org.apache.uima.resource.Resource_ImplBase
      extended by org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer
          extended by org.apache.uima.collection.impl.cpm.container.ProcessingContainer_Impl
All Implemented Interfaces:
java.lang.Runnable, CasProcessorController, RunnableContainer, ConfigurableResource, Resource

public class ProcessingContainer_Impl
extends ProcessingContainer
implements RunnableContainer

Manages a pool of CasProcessor instances. Provides access to CasProcessor instance to Processing Thread. Processing threads check out an instance of Cas Processor and when done invoking its process() method return it back to pool. The container aggregates counts and totals on behalf of all instances of Cas Processor. It also manages error and restart thresholds for Cas Processors as a group. Errors are aggregated for all instances of Cas Processor as a group NOT individually. The container takes appropriate actions when threshold are exceeded. What action is taken depends on declaritive specification in the cpe descriptor.


Field Summary
 ServiceProxyPool casProcessorPool
           
 java.util.LinkedList failedCasProcessorList
           
 
Fields inherited from interface org.apache.uima.resource.Resource
PARAM_AGGREGATE_SOFA_MAPPINGS, PARAM_CONFIG_PARAM_SETTINGS, PARAM_PERFORMANCE_TUNING_SETTINGS, PARAM_RESOURCE_MANAGER, PARAM_UIMA_CONTEXT
 
Fields inherited from interface org.apache.uima.collection.impl.base_cpm.container.CasProcessorController
DISABLED, INITIALIZED, KILLED, NOTINITIALIZED, RUNNING
 
Constructor Summary
ProcessingContainer_Impl(CasProcessorConfiguration aCasProcessorConfig, ProcessingResourceMetaData aMetaData, ServiceProxyPool aCasProcessorPool)
          Initialize container with CasProcessor configuration and pool containing instances of CasProcessor instances.
 
Method Summary
 boolean abortCPMOnError()
          Returns true if maximum threshold for errors has been exceeded and the CasProcessor is configured to force CPE shutdown.
 void addBytesIn(long aBytesIn)
          Aggregate total bytes ingested by the CasProcessor.
 void addBytesOut(long aBytesOut)
          Aggregate total bytes processed by this CasProcessor
 void addStat(java.lang.String aStatName, java.lang.Object aStat)
          Add an arbitrary object and bind it to a given name
 void destroy()
          Destroy instances of CasProcessors managed by this container.
 int getAbortCount()
          Return the up todate number of aborts recorded by the container
 java.util.HashMap getAllStats()
          Returns all stats aggregate during the CPM run
 long getBytesIn()
          Returns total number of bytes ingested so far by all CasProcessor instances managed by this container.
 long getBytesOut()
          Returns total number of bytes processed so far by all CasProcessor instances managed by this container.
 CasProcessor getCasProcessor()
          Returns available instance of the CasProcessor from the instance pool.
 CasProcessorConfiguration getCasProcessorConfiguration()
          Returns CasProcessor configuration object.
 java.lang.Object getConfigParameterValue(java.lang.String aParamName)
          Looks up the value of a configuration parameter.
 java.lang.Object getConfigParameterValue(java.lang.String aGroupName, java.lang.String aParamName)
          Looks up the value of a configuration parameter in a group.
 CasProcessorDeployer getDeployer()
          Returns deployer object used to launch the CasProcessor
 long getFetchTime()
           
 int getFilteredCount()
          Returns number of filtered Cas'es
 java.lang.Object getLastCas()
          Deprecated.  
 java.lang.String getLastProcessedEntityId()
          Returns id of the last entity processed by the CasProcessor
 ProcessingResourceMetaData getMetadata()
          Returns component's input/output capabilities
 ResourceMetaData getMetaData()
          Gets the metadata that describes this Resource.
 java.lang.String getName()
          Returns the name of this container.
 ServiceProxyPool getPool()
           
 long getProcessed()
          Returns number of entities processed so far.
 long getRemaining()
          Returns number of entities still to be processed by the CasProcessor It is a delta of total number of entities to be processed by the CPE minus number of entities processed so far.
 int getRestartCount()
          Returns total number of all CasProcessor restarts.
 int getRetryCount()
          Return the up todate number of retries recorded by the container.
 java.lang.Object getStat(java.lang.String aStatName)
          Return an abject identified with a given name
 int getStatus()
          Returns the current status of the CasProcessor
 long getTotalTime()
          Returns total time spent in process()
 void incrementAbortCount(int aCount)
          Increment number of aborted Cas'es due to inability to process the Cas
 void incrementCasProcessorErrors(java.lang.Throwable aThrowable)
          This routine determines what to do with an exception thrown during the CasProcessor processing.
 void incrementFilteredCount(int aCount)
          Increments number of CAS'es filtered by the CasProcessor.
 void incrementProcessed(int aIncrement)
           
 void incrementRestartCount(int aCount)
          Increment number of times the casProcessor was restarted due to failures
 void incrementRetryCount(int aCount)
          Increments number of times CasProceesor failed analyzing Cas'es due to timeout or some other problems
 void incrementStat(java.lang.String aStatName, java.lang.Integer aStat)
          Increment a value of a given stat
 void incrementTotalTime(long aTime)
          Increments total time spend in the process() method of the CasProcessor
 boolean initialize(ResourceSpecifier aSpecifier, java.util.Map aAdditionalParams)
          Initializes this Resource from a ResourceSpecifier.
 boolean isAbortable()
          Determines if instances of CasProcessor managed by this container are abortable.
 boolean isEndOfBatch(CasProcessor aCasProcessor, int aProcessedSize)
           
 boolean isIntegrated()
          Deprecated.  
 boolean isLocal()
          Deprecated.  
 boolean isPaused()
           
 boolean isRemote()
          Deprecated.  
 boolean isSingleFencedService()
           
 void logAbortedCases(java.lang.Object[] abortedCasList)
          Logs Cas'es that could not be processed.
 void pause()
          Pauses the container until resumed.
 boolean processCas(java.lang.Object[] aCasList)
          Returns true if the Cas bundles should be processed by the CasProcessor.
 void reconfigure()
          Instructs this Resource to re-read its configuration parameter settings.
 void releaseCasProcessor(CasProcessor aCasProcessor)
          Returns a given casProcessor instance back to the pool.
 void resetRestartCount()
           
 void resume()
           
 void run()
           
 void setCasProcessorDeployer(CasProcessorDeployer aDeployer)
          Plug in deployer object used to launch/deploy the CasProcessor instance.
 void setConfigParameterValue(java.lang.String aParamName, java.lang.Object aValue)
          Sets the value of a configuration parameter.
 void setConfigParameterValue(java.lang.String aGroupName, java.lang.String aParamName, java.lang.Object aValue)
          Sets the value of a configuration parameter in a group.
 void setLastCas(java.lang.Object aCasObject)
          Deprecated.  
 void setLastProcessedEntityId(java.lang.String aEntityId)
          Copies id of the last entity processed by the CasProcessor
 void setMetadata(ProcessingResourceMetaData aMetadata)
          Sets component's input/output capabilities
 void setProcessed(long aProcessedCount)
          Used when recovering from checkpoint, sets the total number of entities before CPE stopped.
 void setRemaining(long aRemainingCount)
          Copies number of entities the CasProcessor has yet to process.
 void setSingleFencedService(boolean aSingleFencedInstance)
           
 void setStatus(int aStatus)
          Changes the status of the CasProcessor as a group
 void start()
          Deprecated.  
 void stop()
          Deprecated.  
 
Methods inherited from class org.apache.uima.resource.Resource_ImplBase
getCasManager, getLogger, getResourceManager, getUimaContext, getUimaContextAdmin, setLogger, setMetaData
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.uima.resource.Resource
getLogger, getResourceManager, getUimaContext, getUimaContextAdmin, setLogger
 

Field Detail

casProcessorPool

public ServiceProxyPool casProcessorPool

failedCasProcessorList

public java.util.LinkedList failedCasProcessorList
Constructor Detail

ProcessingContainer_Impl

public ProcessingContainer_Impl(CasProcessorConfiguration aCasProcessorConfig,
                                ProcessingResourceMetaData aMetaData,
                                ServiceProxyPool aCasProcessorPool)
                         throws ResourceConfigurationException
Initialize container with CasProcessor configuration and pool containing instances of CasProcessor instances.

Parameters:
aCasProcessorConfig - - CasProcessor configuration as defined in cpe descriptor
aCasProcessorPool - - pool of CasProcessor instances
Throws:
ResourceConfigurationException
Method Detail

getMetadata

public ProcessingResourceMetaData getMetadata()
Returns component's input/output capabilities


setMetadata

public void setMetadata(ProcessingResourceMetaData aMetadata)
Sets component's input/output capabilities

Specified by:
setMetadata in class ProcessingContainer
Parameters:
Capability - - component capabilities

setCasProcessorDeployer

public void setCasProcessorDeployer(CasProcessorDeployer aDeployer)
Plug in deployer object used to launch/deploy the CasProcessor instance. Used for restarts.

Specified by:
setCasProcessorDeployer in class ProcessingContainer
Parameters:
aDeployer - - object responsible for deploying/launching CasProcessor

getDeployer

public CasProcessorDeployer getDeployer()
Returns deployer object used to launch the CasProcessor

Specified by:
getDeployer in class ProcessingContainer
Returns:
- CasProcessorDeployer - deployer object

logAbortedCases

public void logAbortedCases(java.lang.Object[] abortedCasList)
Logs Cas'es that could not be processed.

Specified by:
logAbortedCases in class ProcessingContainer
Parameters:
abortedCasList - - an arrar of Cas'es that could not be processed by this CasProcessor

getBytesIn

public long getBytesIn()
Returns total number of bytes ingested so far by all CasProcessor instances managed by this container.

Specified by:
getBytesIn in class ProcessingContainer
Returns:
- bytes processed

addBytesIn

public void addBytesIn(long aBytesIn)
Aggregate total bytes ingested by the CasProcessor.

Specified by:
addBytesIn in class ProcessingContainer
Parameters:
- - aBytesIn - number of ingested bytes

getBytesOut

public long getBytesOut()
Returns total number of bytes processed so far by all CasProcessor instances managed by this container.

Specified by:
getBytesOut in class ProcessingContainer
Returns:
- bytes processed

addBytesOut

public void addBytesOut(long aBytesOut)
Aggregate total bytes processed by this CasProcessor

Specified by:
addBytesOut in class ProcessingContainer

incrementRestartCount

public void incrementRestartCount(int aCount)
Increment number of times the casProcessor was restarted due to failures

Specified by:
incrementRestartCount in class ProcessingContainer
Parameters:
- - aCount - restart count

getRestartCount

public int getRestartCount()
Returns total number of all CasProcessor restarts.

Specified by:
getRestartCount in class ProcessingContainer
Parameters:
- - number of restarts

incrementRetryCount

public void incrementRetryCount(int aCount)
Increments number of times CasProceesor failed analyzing Cas'es due to timeout or some other problems

Specified by:
incrementRetryCount in class ProcessingContainer
Parameters:
- - aCount - failure count

getRetryCount

public int getRetryCount()
Return the up todate number of retries recorded by the container.

Specified by:
getRetryCount in class ProcessingContainer
Returns:
- retry count

incrementAbortCount

public void incrementAbortCount(int aCount)
Increment number of aborted Cas'es due to inability to process the Cas

Specified by:
incrementAbortCount in class ProcessingContainer
Parameters:
- - aCount - number of aborts while processing Cas'es

getAbortCount

public int getAbortCount()
Return the up todate number of aborts recorded by the container

Specified by:
getAbortCount in class ProcessingContainer
Returns:
- number of failed attempts to analyze CAS'es

incrementFilteredCount

public void incrementFilteredCount(int aCount)
Increments number of CAS'es filtered by the CasProcessor. Filtered CAS'es dont contain required features. Features that are required by the Cas Processor to perform analysis. Dependant feateurs are defined in the filter expression in the CPE descriptor

Specified by:
incrementFilteredCount in class ProcessingContainer
Parameters:
aCount - - number of filtered Cas'es

getFilteredCount

public int getFilteredCount()
Returns number of filtered Cas'es

Specified by:
getFilteredCount in class ProcessingContainer
Returns:
# of filtered Cas'es

getRemaining

public long getRemaining()
Returns number of entities still to be processed by the CasProcessor It is a delta of total number of entities to be processed by the CPE minus number of entities processed so far.

Specified by:
getRemaining in class ProcessingContainer
Returns:
Number of entities yet to be processed

setRemaining

public void setRemaining(long aRemainingCount)
Copies number of entities the CasProcessor has yet to process.

Specified by:
setRemaining in class ProcessingContainer
Parameters:
aRemainingCount - - number of entities to process

setLastProcessedEntityId

public void setLastProcessedEntityId(java.lang.String aEntityId)
Copies id of the last entity processed by the CasProcessor

Specified by:
setLastProcessedEntityId in class ProcessingContainer
Parameters:
- - aEntityId - id of the entity

getLastProcessedEntityId

public java.lang.String getLastProcessedEntityId()
Returns id of the last entity processed by the CasProcessor

Specified by:
getLastProcessedEntityId in class ProcessingContainer
Returns:
- id of entity

setLastCas

@Deprecated
public void setLastCas(java.lang.Object aCasObject)
Deprecated. 

Copies the last Cas Processed

Specified by:
setLastCas in class ProcessingContainer

getLastCas

@Deprecated
public java.lang.Object getLastCas()
Deprecated. 

Returns the last Cas processed

Specified by:
getLastCas in class ProcessingContainer

incrementProcessed

public void incrementProcessed(int aIncrement)

setProcessed

public void setProcessed(long aProcessedCount)
Used when recovering from checkpoint, sets the total number of entities before CPE stopped.

Specified by:
setProcessed in class ProcessingContainer
Parameters:
- - aProcessedCount - number of entities processed before CPE stopped

getProcessed

public long getProcessed()
Returns number of entities processed so far.

Specified by:
getProcessed in class ProcessingContainer
Returns:
- processed - number of entities processed

resetRestartCount

public void resetRestartCount()
Specified by:
resetRestartCount in class ProcessingContainer

incrementTotalTime

public void incrementTotalTime(long aTime)
Increments total time spend in the process() method of the CasProcessor

Specified by:
incrementTotalTime in class ProcessingContainer
Parameters:
aTime - - total time in process()

getTotalTime

public long getTotalTime()
Returns total time spent in process()

Specified by:
getTotalTime in class ProcessingContainer
Returns:
- number of millis spent in process()

abortCPMOnError

public boolean abortCPMOnError()
Returns true if maximum threshold for errors has been exceeded and the CasProcessor is configured to force CPE shutdown. It looks at the value of the action attribute of the element in the cpe descriptor.

Specified by:
abortCPMOnError in class ProcessingContainer
Returns:
- true if the CPE should stop processing, false otherwise

incrementCasProcessorErrors

public void incrementCasProcessorErrors(java.lang.Throwable aThrowable)
                                 throws java.lang.Exception
This routine determines what to do with an exception thrown during the CasProcessor processing. It interprets given exception and throws a new one according to configuration specified in the CPE descriptor. It examines provided thresholds and determines if the CPE should continue to run, if it should disable the CasProcessor (and all its instances), or disregard the error and continue.

Specified by:
incrementCasProcessorErrors in class ProcessingContainer
Throws:
AbortCPMException - - force the CPE to stop processing
AbortCasProcessorException - - disables all instances of CasProcessor in this container
ServiceConnectionException - - forces the restart/relauch of the failed CasProcessor
SkipCasException - - disregard error, skip bad Cas'es and continue with the next Cas bundle
java.lang.Exception

isEndOfBatch

public boolean isEndOfBatch(CasProcessor aCasProcessor,
                            int aProcessedSize)
                     throws ResourceProcessException,
                            java.io.IOException
Specified by:
isEndOfBatch in class ProcessingContainer
Throws:
ResourceProcessException
java.io.IOException

processCas

public boolean processCas(java.lang.Object[] aCasList)
Returns true if the Cas bundles should be processed by the CasProcessor. This routine checks for existance of dependent featues defined in the filter expression defined for the CasProcessor in the cpe descriptor. Currently this is done on per bundle basis. Meaning that all Cas'es must contain required features. If even one Cas does not have them, the entire bundle is skipped.

Specified by:
processCas in class ProcessingContainer
Parameters:
aCasList - - bundle containing instances of CAS

getCasProcessorConfiguration

public CasProcessorConfiguration getCasProcessorConfiguration()
Returns CasProcessor configuration object. This object represents xml configuration defined in the section of the cpe descriptor.

Specified by:
getCasProcessorConfiguration in class ProcessingContainer
Returns:
CasProcessorConfiguration instance

start

@Deprecated
public void start()
Deprecated. 

Description copied from interface: RunnableContainer
Starts the container

Specified by:
start in interface RunnableContainer

stop

@Deprecated
public void stop()
Deprecated. 

Description copied from interface: RunnableContainer
Stops the container

Specified by:
stop in interface RunnableContainer

getCasProcessor

public CasProcessor getCasProcessor()
Returns available instance of the CasProcessor from the instance pool. It will wait indefinitely until an instance is available.

Specified by:
getCasProcessor in interface CasProcessorController
Returns:
CasProcessor

releaseCasProcessor

public void releaseCasProcessor(CasProcessor aCasProcessor)
Returns a given casProcessor instance back to the pool.

Specified by:
releaseCasProcessor in class ProcessingContainer
Parameters:
aCasProcessor - - an instance of CasProcessor to return back to the pool
See Also:
ProcessingContainer.releaseCasProcessor(org.apache.uima.collection.base_cpm.CasProcessor)

getStatus

public int getStatus()
Returns the current status of the CasProcessor

Specified by:
getStatus in interface CasProcessorController
Returns:
int status

setStatus

public void setStatus(int aStatus)
Changes the status of the CasProcessor as a group

Specified by:
setStatus in interface CasProcessorController
Parameters:
aStatus - - new status

isLocal

@Deprecated
public boolean isLocal()
Deprecated. 

Description copied from interface: CasProcessorController
Returns true if this is a Locally Deployed CasProcessor ( Same machine, different JVM )

Specified by:
isLocal in interface CasProcessorController
Returns:
true if Local, false otherwise

isRemote

@Deprecated
public boolean isRemote()
Deprecated. 

Description copied from interface: CasProcessorController
Returns true if this is a Remotely Deployed CasProcessor

Specified by:
isRemote in interface CasProcessorController
Returns:
true if Remote, false otherwise

isIntegrated

@Deprecated
public boolean isIntegrated()
Deprecated. 

Description copied from interface: CasProcessorController
Returns true if this is a Integrated CasProcessor

Specified by:
isIntegrated in interface CasProcessorController
Returns:
true if Integrated, false otherwise

isAbortable

public boolean isAbortable()
Determines if instances of CasProcessor managed by this container are abortable. Abortable CasProcessor's action attribute in the element has a value of 'disable'.

Specified by:
isAbortable in interface CasProcessorController
Returns:
true if CasProcessor can be disabled

initialize

public boolean initialize(ResourceSpecifier aSpecifier,
                          java.util.Map aAdditionalParams)
                   throws ResourceInitializationException
Description copied from interface: Resource
Initializes this Resource from a ResourceSpecifier. Applications do not need to call this method. It is called automatically by the ResourceFactory and cannot be called a second time.

Specified by:
initialize in interface Resource
Overrides:
initialize in class Resource_ImplBase
Parameters:
aSpecifier - specifies how to create a resource or locate an existing resource service.
aAdditionalParams - a Map containing additional parameters. May be null if there are no parameters. Each class that implements this interface can decide what additional parameters it supports.
Returns:
true if and only if initialization completed successfully. Reutrns false if the given ResourceSpecifier is not of an appropriate type for this Resource. If the ResourceSpecifier is of an appropriate type but is invalid or if some other failure occurs, an exception should be thrown.
Throws:
ResourceInitializationException - if a failure occurs during initialization.
See Also:
Resource.initialize(org.apache.uima.resource.ResourceSpecifier, java.util.Map)

destroy

public void destroy()
Destroy instances of CasProcessors managed by this container. Before destroying the instance, this method notifies it with CollectionProcessComplete so that the component finalizes its logic and does appropriate cleanup before shutdown.

Specified by:
destroy in interface Resource
Overrides:
destroy in class Resource_ImplBase
See Also:
Resource.destroy()

run

public void run()
Specified by:
run in interface java.lang.Runnable

getConfigParameterValue

public java.lang.Object getConfigParameterValue(java.lang.String aParamName)
Description copied from interface: ConfigurableResource
Looks up the value of a configuration parameter. This method will only return the value of a parameter that is not defined in any group.

This method returns null if the parameter is optional and has not been assigned a value. (For mandatory parameters, an exception is thrown during initialization if no value has been assigned.) This method also returns null if there is no declared configuration parameter with the specified name.

Specified by:
getConfigParameterValue in interface ConfigurableResource
Parameters:
aParamName - the name of a parameter that is not in any group
Returns:
the value of the parameter with name aParamName, null is either the parameter does not exist or it has not been assigned a value.

getConfigParameterValue

public java.lang.Object getConfigParameterValue(java.lang.String aGroupName,
                                                java.lang.String aParamName)
Description copied from interface: ConfigurableResource
Looks up the value of a configuration parameter in a group. If the parameter has no value assigned within the group, fallback strategies will be followed.

This method returns null if the parameter is optional and has not been assigned a value. (For mandatory parameters, an exception is thrown during initialization if no value has been assigned.) This method also returns null if there is no declared configuration parameter with the specified name.

Specified by:
getConfigParameterValue in interface ConfigurableResource
Parameters:
aGroupName - the name of a configuration group. If the group name is null, this method will return the same value as getParameterValue(String).
aParamName - the name of a parameter in the group
Returns:
the value of the parameter in group aGroupName with name aParamName,,null is either the parameter does not exist or it has not been assigned a value.

setConfigParameterValue

public void setConfigParameterValue(java.lang.String aParamName,
                                    java.lang.Object aValue)
Description copied from interface: ConfigurableResource
Sets the value of a configuration parameter. This only works for a parameter that is not defined in any group. Note that there is no guarantee that the change will take effect until ConfigurableResource.reconfigure() is called.

Specified by:
setConfigParameterValue in interface ConfigurableResource
Parameters:
aParamName - the name of a parameter that is not in any group
aValue - the value to assign to the parameter

setConfigParameterValue

public void setConfigParameterValue(java.lang.String aGroupName,
                                    java.lang.String aParamName,
                                    java.lang.Object aValue)
Description copied from interface: ConfigurableResource
Sets the value of a configuration parameter in a group. Note that there is no guarantee that the change will take effect until ConfigurableResource.reconfigure() is called.

Specified by:
setConfigParameterValue in interface ConfigurableResource
Parameters:
aGroupName - the name of a configuration group. If this parameter is null, this method will have the same effet as setParameterValue(String,Object).
aParamName - the name of a parameter in the group
aValue - the value to assign to the parameter.

reconfigure

public void reconfigure()
                 throws ResourceConfigurationException
Description copied from interface: ConfigurableResource
Instructs this Resource to re-read its configuration parameter settings.

Specified by:
reconfigure in interface ConfigurableResource
Throws:
ResourceConfigurationException - if the configuration is not valid

getName

public java.lang.String getName()
Returns the name of this container. It is the name of the Cas Processor.

Specified by:
getName in class ProcessingContainer

getMetaData

public ResourceMetaData getMetaData()
Description copied from interface: Resource
Gets the metadata that describes this Resource.

Specified by:
getMetaData in interface Resource
Overrides:
getMetaData in class Resource_ImplBase
Returns:
an object containing all metadata for this resource.
See Also:
Resource.getMetaData()

incrementStat

public void incrementStat(java.lang.String aStatName,
                          java.lang.Integer aStat)
Increment a value of a given stat

Specified by:
incrementStat in class ProcessingContainer

addStat

public void addStat(java.lang.String aStatName,
                    java.lang.Object aStat)
Add an arbitrary object and bind it to a given name

Specified by:
addStat in class ProcessingContainer

getStat

public java.lang.Object getStat(java.lang.String aStatName)
Return an abject identified with a given name

Specified by:
getStat in class ProcessingContainer

getAllStats

public java.util.HashMap getAllStats()
Returns all stats aggregate during the CPM run

Specified by:
getAllStats in class ProcessingContainer
Returns:

pause

public void pause()
Pauses the container until resumed. The CPM will pause to the Container while it is trying to re-connect to a shared remote service. While the Container is paused getCasProcessor() will not be allowed to return a new CasProcessor. All other methods are accessible and will function fine.

Specified by:
pause in class ProcessingContainer

resume

public void resume()
Specified by:
resume in class ProcessingContainer

isPaused

public boolean isPaused()
Specified by:
isPaused in class ProcessingContainer

getPool

public ServiceProxyPool getPool()
Specified by:
getPool in class ProcessingContainer

setSingleFencedService

public void setSingleFencedService(boolean aSingleFencedInstance)
Specified by:
setSingleFencedService in class ProcessingContainer

isSingleFencedService

public boolean isSingleFencedService()
Specified by:
isSingleFencedService in class ProcessingContainer

getFetchTime

public long getFetchTime()


Copyright © 2011. All Rights Reserved.