Package org.nuxeo.elasticsearch.work

Class AbstractIndexingWorker

java.lang.Object

org.nuxeo.ecm.core.work.AbstractWork

org.nuxeo.elasticsearch.work.BaseIndexingWorker

org.nuxeo.elasticsearch.work.AbstractIndexingWorker

All Implemented Interfaces:

Serializable, Work

Direct Known Subclasses:

ChildrenIndexingWorker, IndexingWorker

public abstract class AbstractIndexingWorker
extends BaseIndexingWorker

Abstract class for sharing code between ElasticSearch related workers

Author:

Tiry

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.nuxeo.ecm.core.work.api.Work

Work.Progress, Work.State

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<IndexingCommand>	cmds

Fields inherited from class org.nuxeo.ecm.core.work.AbstractWork

callerThread, completionTime, docId, docIds, FAILURE_EXCEPTION, FAILURE_MSG, GLOBAL_DLQ_COUNT_REGISTRY_NAME, id, isTree, loginContext, originatingUsername, progress, RANDOM, repositoryName, schedulePath, schedulingTime, session, startTime, state, status, suspended, suspending, traceContext, WORK_FAILED_EVENT, WORK_INSTANCE

Constructor Summary

Constructors

Constructor	Description
AbstractIndexingWorker(String repositoryName, List<IndexingCommand> cmds)
AbstractIndexingWorker(IndexingCommand cmd)

Method Summary

Modifier and Type	Method	Description
protected abstract void	doIndexingWork(ElasticSearchIndexing esi, List<IndexingCommand> cmds)
void	doWork()

Methods inherited from class org.nuxeo.elasticsearch.work.BaseIndexingWorker

getCategory, getRetryCount, work

Methods inherited from class org.nuxeo.ecm.core.work.AbstractWork

appendWorkToDeadLetterQueue, buildWorkFailureEventProps, cleanUp, closeSession, commitOrRollbackTransaction, equals, getCompletionTime, getDocument, getDocuments, getId, getOriginatingUsername, getPartitionKey, getProgress, getSchedulePath, getSchedulingTime, getSpanFromContext, getStartTime, getStatus, getWorkInstanceState, hashCode, isDocumentTree, isSuspending, isWorkInstanceSuspended, newDocumentLocation, openSystemSession, openUserSession, run, runWorkWithTransaction, setCompletionTime, setDocument, setDocument, setDocuments, setOriginatingUsername, setProgress, setSchedulePath, setStartTime, setStatus, setWorkInstanceState, setWorkInstanceSuspending, startTransaction, suspended, toString, workFailed

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.nuxeo.ecm.core.work.api.Work

getTitle, isCoalescing, isGroupJoin, isIdempotent, onGroupJoinCompletion

Field Details

cmds

protected final List<IndexingCommand> cmds

Constructor Details

AbstractIndexingWorker

public AbstractIndexingWorker(IndexingCommand cmd)

AbstractIndexingWorker

public AbstractIndexingWorker(String repositoryName,
 List<IndexingCommand> cmds)

Method Details

doWork

public void doWork()

Specified by:

doWork in class BaseIndexingWorker

doIndexingWork

protected abstract void doIndexingWork(ElasticSearchIndexing esi,
 List<IndexingCommand> cmds)