ProcessorPauseResume (org.codehaus.gpars)

Overview

Package

Class

Deprecated

Index

Help

org.codehaus.gpars

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.dataflow.operator.component
[Java] Class ProcessorPauseResume

java.lang.Object
  groovyx.gpars.dataflow.operator.DataflowEventAdapter
      groovyx.gpars.dataflow.operator.component.ProcessorPauseResume

public final class ProcessorPauseResume
extends DataflowEventAdapter

A listener to dataflow operators and selectors allowing them to be paused and resumed.

Field Summary
`private boolean`	`paused`

Constructor Summary
`ProcessorPauseResume()`

Method Summary
`java.util.List`	`beforeRun(DataflowProcessor processor, java.util.List messages)`
`void`	`pause()` Resumes the operator so that it can start processing messages again.
`void`	`resume()`

Methods inherited from class DataflowEventAdapter
afterRun, afterStart, afterStop, beforeRun, controlMessageArrived, customEvent, messageArrived, messageSentOut, onException, registered

Field Detail

private boolean paused

Constructor Detail

ProcessorPauseResume()

Method Detail

@java.lang.Override* when pausing multiple operators.
public java.util.List beforeRun(DataflowProcessor processor, java.util.List messages)

public void pause()

Resumes the operator so that it can start processing messages again.

public void resume()