groovyx.gpars.dataflow.impl
Class DataflowChannelEventOrchestrator<T>

java.lang.Object
  groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator<T>

All Implemented Interfaces:

DataflowChannelEventDistibutor<T>, DataflowChannelEventListenerManager<T>

public final class DataflowChannelEventOrchestrator<T>
extends java.lang.Object
implements DataflowChannelEventListenerManager<T>, DataflowChannelEventDistibutor<T>

Groups the listener-related functionality shared by dataflow channels

Author:

Vaclav Pech

Field Summary

private java.util.Collection<DataflowChannelListener<T>>

listeners

Constructor Summary

DataflowChannelEventOrchestrator()

Method Summary

void	addAllDataflowChannelListeners(java.util.Collection<DataflowChannelListener<T>> listeners)
void	addDataflowChannelListener(DataflowChannelListener<T> listener)
void	fireOnMessage(T message)
java.util.Collection<DataflowChannelListener<T>>	getListeners()
void	removeDataflowChannelListener(DataflowChannelListener<T> listener)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

listeners

private final java.util.Collection<DataflowChannelListener<T>> listeners

Constructor Detail

DataflowChannelEventOrchestrator

public DataflowChannelEventOrchestrator()

Method Detail

addDataflowChannelListener

public void addDataflowChannelListener(DataflowChannelListener<T> listener)

Specified by:

addDataflowChannelListener in interface DataflowChannelEventListenerManager<T>

addAllDataflowChannelListeners

public void addAllDataflowChannelListeners(java.util.Collection<DataflowChannelListener<T>> listeners)

Specified by:

addAllDataflowChannelListeners in interface DataflowChannelEventListenerManager<T>

removeDataflowChannelListener

public void removeDataflowChannelListener(DataflowChannelListener<T> listener)

Specified by:

removeDataflowChannelListener in interface DataflowChannelEventListenerManager<T>

getListeners

public java.util.Collection<DataflowChannelListener<T>> getListeners()

Specified by:

getListeners in interface DataflowChannelEventListenerManager<T>

fireOnMessage

public void fireOnMessage(T message)

Specified by:

fireOnMessage in interface DataflowChannelEventDistibutor<T>