DataflowEventListener (org.codehaus.gpars)

Overview

Package

Class

Deprecated

Index

Help

org.codehaus.gpars

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | METHOD

DETAIL: FIELD | METHOD

groovyx.gpars.dataflow.operator
[Java] Interface DataflowEventListener

public interface DataflowEventListener

Enables external entities to observe the state of dataflow selectors and operators

Method Summary
`void`	`afterRun(DataflowProcessor processor, java.util.List messages)`
`void`	`afterStart(DataflowProcessor processor)`
`void`	`afterStop(DataflowProcessor processor)`
`java.util.List`	`beforeRun(DataflowProcessor processor, java.util.List messages)`
`java.lang.Object`	`controlMessageArrived(DataflowProcessor processor, DataflowReadChannel channel, int index, java.lang.Object message)`
`java.lang.Object`	`customEvent(DataflowProcessor processor, java.lang.Object data)`
`java.lang.Object`	`messageArrived(DataflowProcessor processor, DataflowReadChannel channel, int index, java.lang.Object message)`
`java.lang.Object`	`messageSentOut(DataflowProcessor processor, DataflowWriteChannel channel, int index, java.lang.Object message)`
`boolean`	`onException(DataflowProcessor processor, java.lang.Throwable e)`
`void`	`registered(DataflowProcessor processor)` Invoked immediately after the operator terminates

Method Detail

public void afterRun(DataflowProcessor processor, java.util.List messages)

public void afterStart(DataflowProcessor processor)

public void afterStop(DataflowProcessor processor)

public java.util.List beforeRun(DataflowProcessor processor, java.util.List messages)

public java.lang.Object controlMessageArrived(DataflowProcessor processor, DataflowReadChannel channel, int index, java.lang.Object message)

public java.lang.Object customEvent(DataflowProcessor processor, java.lang.Object data)

public java.lang.Object messageArrived(DataflowProcessor processor, DataflowReadChannel channel, int index, java.lang.Object message)

public java.lang.Object messageSentOut(DataflowProcessor processor, DataflowWriteChannel channel, int index, java.lang.Object message)

public boolean onException(DataflowProcessor processor, java.lang.Throwable e)

public void registered(DataflowProcessor processor)

Invoked immediately after the operator terminates