Modifier and Type | Method and Description |
---|---|
void |
abort()
Cancel this Job.
|
void |
announceSubPipelineCreation(Node parent,
Set<? extends Node> createdNodes)
Propagate that new
Node s were created in a sub-pipeline on behalf
of another node. |
void |
error(NodeWorker<?> worker,
com.levigo.util.log.qualified.QualifiedLogEvent message)
Propagate a non-fatal, possibly pertaining to a particular node and worker.
|
long |
getAge()
Calculate the age of this job, i.e.
|
Job |
getClientJob()
|
File |
getServerTempDir()
Get the temporary directory jadice server uses.
|
File |
getTempDir() |
NodeWorkerFactory |
getWorkerFactory() |
void |
processingFailed(NodeWorker<?> worker,
com.levigo.util.log.qualified.QualifiedLogEvent message)
Handle a processing failure, possibly pertaining to a particular node and worker.
|
void |
startWorkers(Collection<NodeWorker<?>> workers)
Start worker threads for a given sub-pipeline.
|
void |
warning(NodeWorker<?> worker,
com.levigo.util.log.qualified.QualifiedLogEvent message)
Propagate a warning, possibly pertaining to a particular node and worker.
|
void abort()
void processingFailed(NodeWorker<?> worker, com.levigo.util.log.qualified.QualifiedLogEvent message)
worker
- The worker
that caused the failuremessage
- Reason of the failurevoid warning(NodeWorker<?> worker, com.levigo.util.log.qualified.QualifiedLogEvent message)
worker
- The worker
that caused the warningmessage
- Reason of the warningvoid error(NodeWorker<?> worker, com.levigo.util.log.qualified.QualifiedLogEvent message)
worker
- The worker
that caused the errormessage
- Reason of the errorvoid startWorkers(Collection<NodeWorker<?>> workers)
workers
- File getTempDir()
getServerTempDir()
File getServerTempDir()
getTempDir()
.getTempDir()
void announceSubPipelineCreation(Node parent, Set<? extends Node> createdNodes)
Node
s were created in a sub-pipeline on behalf
of another node.parent
- The node that triggered the creationcreatedNodes
- The nodes that were created.long getAge()
NodeWorkerFactory getWorkerFactory()
Copyright © 2017 levigo holding gmbh. All rights reserved.