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 long
ASSIGNMENT_TIMEOUT_SECONDS
protected StringList
categoryFilter
protected long
countFiltered
protected long
countSuccess
protected long
countTotal
protected static long
DEFAULT_TIMEOUT_SECONDS
protected boolean
dryRun
static String
ID
protected long
timeout
-
Constructor Summary
Constructors Constructor Description WorkManagerRunWorkInFailure()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Blob
buildResult()
protected ComputationPolicy
getComputationPolicy()
protected Duration
getTimeout()
protected Topology
getTopology()
Blob
run()
-
-
-
Field Detail
-
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
-
-
Method Detail
-
run
public Blob run() throws IOException, InterruptedException, TimeoutException
-
buildResult
protected Blob buildResult() throws IOException
- Throws:
IOException
-
getTimeout
protected Duration getTimeout()
-
getComputationPolicy
protected ComputationPolicy getComputationPolicy()
-
getTopology
protected Topology getTopology()
-
-