A listener to dataflow operators and selectors allowing them to be paused and resumed.
| Modifiers | Name | Description |
|---|---|---|
private boolean |
paused |
| Constructor and description |
|---|
ProcessorPauseResume
() |
| Type | Name and description |
|---|---|
java.util.List<java.lang.Object> |
beforeRun(DataflowProcessor processor, java.util.List<java.lang.Object> messages) |
void |
pause()Pauses the operator so that it blocks the next time it attempts to process a message. |
void |
resume()Resumes the operator so that it can start processing messages again. |
| Methods inherited from class | Name |
|---|---|
class DataflowEventAdapter |
afterRun, afterStart, afterStop, beforeRun, controlMessageArrived, customEvent, messageArrived, messageSentOut, onException, registered |
class java.lang.Object |
java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |
Pauses the operator so that it blocks the next time it attempts to process a message. The operator's thread will be blocked, so care should be taken in order not to exhaust all available operator threads when pausing multiple operators.
Resumes the operator so that it can start processing messages again.
Copyright © 2008–2014 Václav Pech. All Rights Reserved.