Modifier and Type | Method and Description |
---|---|
Job |
Node.getJob()
Get the associated job, or
null if the node is not yet
initialized. |
Modifier and Type | Method and Description |
---|---|
void |
JobListener.errorOccurred(Job job,
Node node,
String messageId,
String message,
Throwable cause)
Receive notification about a non-fatal error during job execution.
|
void |
JobListenerAdapter.errorOccurred(Job job,
Node node,
String messageId,
String message,
Throwable cause) |
void |
JobListener.executionFailed(Job job,
Node node,
String messageId,
String reason,
Throwable cause)
Receive notification about a failed job execution.
|
void |
JobListenerAdapter.executionFailed(Job job,
Node node,
String messageId,
String reason,
Throwable cause) |
void |
JobListener.stateChanged(Job job,
Job.State oldState,
Job.State newState)
Receive notification about the job's state having changed.
|
void |
JobListenerAdapter.stateChanged(Job job,
Job.State oldState,
Job.State newState) |
void |
JobListener.subPipelineCreated(Job job,
Node parent,
Set<? extends Node> createdNodes)
|
void |
JobListenerAdapter.subPipelineCreated(Job job,
Node parent,
Set<? extends Node> createdNodes) |
void |
JobListener.warningOccurred(Job job,
Node node,
String messageId,
String message,
Throwable cause)
Receive notification about a warning during job execution.
|
void |
JobListenerAdapter.warningOccurred(Job job,
Node node,
String messageId,
String message,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
Job |
JobFactory.createJob()
Create a job with the defaults as defined by the particular JobFactory
implementation.
|
Modifier and Type | Method and Description |
---|---|
Job |
JobExecutionContext.getClientJob() |
Job |
ServerJob.getClientJob()
|
Job |
NodeWorker.getJob() |
Constructor and Description |
---|
LimitSupport(ServerJob job,
Job clientJob)
Create a job dependent
LimitSupport (i.e. |
Modifier and Type | Method and Description |
---|---|
Job |
JMSJobFactory.createJob()
Create a job for the specified
QueueConnectionFactory and the
given default values (see the "see also" section). |
Modifier and Type | Method and Description |
---|---|
Job |
JMSJobExecutionContext.getClientJob() |
Modifier and Type | Method and Description |
---|---|
Job |
StreamScriptContext.getClientJob() |
Modifier and Type | Method and Description |
---|---|
void |
TraceListener.errorOccurred(Job job,
Node node,
String messageId,
String message,
Throwable cause)
Causes a
Log#error(Object, Throwable) . |
void |
TraceListener.executionFailed(Job job,
Node node,
String messageId,
String reason,
Throwable cause)
Causes a
Log#fatal(Object, Throwable) . |
void |
TraceListener.stateChanged(Job job,
Job.State oldState,
Job.State newState)
Causes a
Log#info(Object) . |
void |
TraceListener.subPipelineCreated(Job job,
Node parent,
Set<? extends Node> createdNodes)
Causes a
Log#info(Object) |
void |
TraceListener.warningOccurred(Job job,
Node node,
String messageId,
String message,
Throwable cause)
Causes a
Log#warn(Object, Throwable) . |
Copyright © 2017 levigo holding gmbh. All rights reserved.