public static class ReactorListener.Aggregator extends Object implements ReactorListener
ReactorListener.Aggregator
NOOP
Constructor and Description |
---|
Aggregator(Collection<ReactorListener> listeners) |
Modifier and Type | Method and Description |
---|---|
void |
onAttained(Milestone milestone)
Indicates that the following milestone was attained.
|
void |
onTaskCompleted(Task t)
Notifies that the execution of the task is about to finish.
|
void |
onTaskFailed(Task t,
Throwable err,
boolean fatal)
Notifies that the execution of the task have failed with an exception.
|
void |
onTaskStarted(Task t)
Notifies that the execution of the task is about to start.
|
public Aggregator(Collection<ReactorListener> listeners)
public void onTaskStarted(Task t)
ReactorListener
onTaskStarted
in interface ReactorListener
public void onTaskCompleted(Task t)
ReactorListener
ReactorListener.onTaskStarted(Task)
.onTaskCompleted
in interface ReactorListener
public void onTaskFailed(Task t, Throwable err, boolean fatal)
ReactorListener
onTaskFailed
in interface ReactorListener
err
- Either Error
or Exception
, indicating the cause of the failure.fatal
- If true, this problem is fatal, and the reactor
is going to terminate. If false, the reactor will continue executing after this failure.public void onAttained(Milestone milestone)
ReactorListener
onAttained
in interface ReactorListener
Copyright © 2014. All rights reserved.