public class WorkManagerComputationChronicle extends WorkManagerComputation
WorkManagerComputation.WorkScheduling
WorkManagerImpl.WorkCompletionSynchronizer, WorkManagerImpl.WorkThreadPoolExecutor
WorkManager.Scheduling
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
log |
DEFAULT_CONCURRENCY, manager, mqManager, settings, streamIds, topology
completionSynchronizer, DEFAULT_CATEGORY, DEFAULT_QUEUE_ID, executors, IMPL_EP, NAME, QUEUES_EP, queuing, registry, shutdownInProgress, started, THREAD_PREFIX, workQueueConfig, workQueuingConfig
lastModified
Constructor and Description |
---|
WorkManagerComputationChronicle() |
Modifier and Type | Method and Description |
---|---|
protected int |
getOverProvisioningFactor() |
protected MQManager<Record> |
initStream() |
awaitCompletion, find, getApplicationStartedOrder, getMetrics, getPartitions, getQueueSize, getStreamForCategory, getWorkState, init, initTopology, listWork, listWorkIds, schedule, scheduleAfterCommit, shutdown, shutdownQueue, start, startComputation, supplantWorkManagerImpl
awaitCompletion, enableProcessing, enableProcessing, getCategoryQueueId, getExecutor, getTimestampAfter, getWorkQueueDescriptor, getWorkQueueIds, hasWorkInState, isProcessingEnabled, isProcessingEnabled, isQueuingEnabled, isStarted, newWorkQueuing, noScheduledOrRunningWork, registerContribution, remainingMillis, removeExecutor, schedule, schedule, schedule, shutdownExecutors, stop, unregisterContribution
activate, deactivate, getAdapter, getLastModified, registerExtension, setLastModified, setModifiedNow, unregisterExtension
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
applicationStarted
protected static final org.apache.commons.logging.Log log
public WorkManagerComputationChronicle()
protected MQManager<Record> initStream()
initStream
in class WorkManagerComputation
protected int getOverProvisioningFactor()
getOverProvisioningFactor
in class WorkManagerComputation
Copyright © 2017 Nuxeo. All rights reserved.