public class WorkManagerComputationKafka extends WorkManagerComputation
WorkManagerComputation.WorkScheduling
WorkManagerImpl.WorkCompletionSynchronizer, WorkManagerImpl.WorkThreadPoolExecutor
WorkManager.Scheduling
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_CONFIG |
static String |
DEFAULT_OVERPROVISIONING |
protected static org.apache.commons.logging.Log |
log |
static String |
NUXEO_WORKMANAGER_KAFKA_CONFIG_PROP |
static String |
NUXEO_WORKMANAGER_KAFKA_OVERPROVISIONING_PROP |
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 |
---|
WorkManagerComputationKafka() |
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 static final String NUXEO_WORKMANAGER_KAFKA_CONFIG_PROP
public static final String NUXEO_WORKMANAGER_KAFKA_OVERPROVISIONING_PROP
public static final String DEFAULT_CONFIG
public static final String DEFAULT_OVERPROVISIONING
public WorkManagerComputationKafka()
protected MQManager<Record> initStream()
initStream
in class WorkManagerComputation
protected int getOverProvisioningFactor()
getOverProvisioningFactor
in class WorkManagerComputation
Copyright © 2017 Nuxeo. All rights reserved.