Package org.nuxeo.ecm.automation.core.operations.services.workmanager

Class WorkManagerRunWorkInFailure

java.lang.Object

org.nuxeo.ecm.automation.core.operations.services.workmanager.WorkManagerRunWorkInFailure

public class WorkManagerRunWorkInFailure
extends Object

Executes Works stored in the dead letter queue after failure.

Since:

11.1

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	WorkManagerRunWorkInFailure.WorkFailureComputation

Field Summary

Fields

Modifier and Type	Field	Description
protected static final long	ASSIGNMENT_TIMEOUT_SECONDS
protected StringList	categoryFilter
protected long	countFiltered
protected long	countSuccess
protected long	countTotal
protected static final long	DEFAULT_TIMEOUT_SECONDS
protected boolean	dryRun
static final String	ID
protected long	timeout

Constructor Summary

Constructors

Constructor	Description
WorkManagerRunWorkInFailure()

Method Summary

Modifier and Type	Method	Description
protected Blob	buildResult()
protected ComputationPolicy	getComputationPolicy()
protected Duration	getTimeout()
protected Topology	getTopology()
Blob	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ID

public static final String ID

See Also:

• Constant Field Values

DEFAULT_TIMEOUT_SECONDS

protected static final long DEFAULT_TIMEOUT_SECONDS

See Also:

• Constant Field Values

ASSIGNMENT_TIMEOUT_SECONDS

protected static final long ASSIGNMENT_TIMEOUT_SECONDS

See Also:

• Constant Field Values

countTotal

protected volatile long countTotal

countSuccess

protected volatile long countSuccess

countFiltered

protected volatile long countFiltered

timeout

protected long timeout

dryRun

protected boolean dryRun

categoryFilter

protected StringList categoryFilter

Constructor Details

WorkManagerRunWorkInFailure

public WorkManagerRunWorkInFailure()

Method Details

run

public Blob run()
         throws IOException,
InterruptedException,
TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

buildResult

protected Blob buildResult()
                    throws IOException

Throws:

IOException

getTimeout

protected Duration getTimeout()

getComputationPolicy

protected ComputationPolicy getComputationPolicy()

getTopology

protected Topology getTopology()