DataflowChannelEventOrchestrator (org.codehaus.gpars)

groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator

All Implemented Interfaces and Traits:

BindErrorDistributor, BindErrorListenerManager, DataflowChannelEventDistributor, DataflowChannelEventListenerManager
```
public final class DataflowChannelEventOrchestrator
extends java.lang.Object
```
Groups the listener-related functionality shared by dataflow channels
Authors:
Vaclav Pech

Field Summary

Fields
Modifiers	Name	Description
`private java.util.Collection<BindErrorListener<T>>`	`BindErrorListener`
`private java.util.Collection<DataflowChannelListener<T>>`	`listeners`

Constructor Summary

Constructors
Constructor and description
`DataflowChannelEventOrchestrator ()`

Methods Summary

Methods
Type	Name and description
`void`	`addAllBindErrorListeners(java.util.Collection<BindErrorListener<T>> listeners)`
`void`	`addAllDataflowChannelListeners(java.util.Collection<DataflowChannelListener<T>> listeners)`
`void`	`addBindErrorListener(BindErrorListener<T> listener)`
`void`	`addDataflowChannelListener(DataflowChannelListener<T> listener)`
`void`	`fireBindError(T oldValue, T failedValue, boolean uniqueBind)` Notifies all listeners about failed bind operations
`void`	`fireBindError(T oldValue, java.lang.Throwable failedError)` Notifies all listeners about failed bindError operations
`void`	`fireBindError(java.lang.Throwable oldError, T failedValue, boolean uniqueBind)` Notifies all listeners about failed bind operations
`void`	`fireBindError(java.lang.Throwable oldError, java.lang.Throwable failedError)` Notifies all listeners about failed bindError operations
`void`	`fireOnMessage(T message)`
`java.util.Collection<BindErrorListener<T>>`	`getBindErrorListeners()`
`java.util.Collection<DataflowChannelListener<T>>`	`getListeners()`
`void`	`removeBindErrorListener(BindErrorListener<T> listener)`
`void`	`removeDataflowChannelListener(DataflowChannelListener<T> listener)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`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()`

- Field Detail
  - private final java.util.Collection<BindErrorListener<T>> BindErrorListener
  - private final java.util.Collection<DataflowChannelListener<T>> listeners
- Constructor Detail
  - DataflowChannelEventOrchestrator()
- Method Detail
  - @java.lang.Override public void addAllBindErrorListeners(java.util.Collection<BindErrorListener<T>> listeners)
  - @java.lang.Override public void addAllDataflowChannelListeners(java.util.Collection<DataflowChannelListener<T>> listeners)
  - @java.lang.Override public void addBindErrorListener(BindErrorListener<T> listener)
  - @java.lang.Override public void addDataflowChannelListener(DataflowChannelListener<T> listener)
  - @java.lang.Override public void fireBindError(T oldValue, T failedValue, boolean uniqueBind)
    
    Notifies all listeners about failed bind operations
    Parameters:
    oldValue - The already bound value
    failedValue - The value attempted to be bound
    uniqueBind - Flag indicating bindUnique() method call
  - @java.lang.Override public void fireBindError(T oldValue, java.lang.Throwable failedError)
    
    Notifies all listeners about failed bindError operations
    Parameters:
    oldValue - The already bound value
    failedError - The error attempted to be bound
  - @java.lang.Override public void fireBindError(java.lang.Throwable oldError, T failedValue, boolean uniqueBind)
    
    Notifies all listeners about failed bind operations
    Parameters:
    oldError - The already bound Throwable
    failedValue - The value attempted to be bound
    uniqueBind - Flag indicating bindUnique() method call
  - @java.lang.Override public void fireBindError(java.lang.Throwable oldError, java.lang.Throwable failedError)
    
    Notifies all listeners about failed bindError operations
    Parameters:
    oldError - The already bound Throwable
    failedError - The error attempted to be bound
  - @java.lang.Override public void fireOnMessage(T message)
  - @java.lang.SuppressWarnings("ReturnOfCollectionOrArrayField") @java.lang.Override public java.util.Collection<BindErrorListener<T>> getBindErrorListeners()
  - @java.lang.SuppressWarnings("ReturnOfCollectionOrArrayField") @java.lang.Override public java.util.Collection<DataflowChannelListener<T>> getListeners()
  - @java.lang.Override public void removeBindErrorListener(BindErrorListener<T> listener)
  - @java.lang.Override public void removeDataflowChannelListener(DataflowChannelListener<T> listener)

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

[Java] Class DataflowChannelEventOrchestrator<T>

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

private final java.util.Collection<BindErrorListener<T>> BindErrorListener

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

Constructor Detail

DataflowChannelEventOrchestrator()

Method Detail

@java.lang.Override public void addAllBindErrorListeners(java.util.Collection<BindErrorListener<T>> listeners)

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

@java.lang.Override public void addBindErrorListener(BindErrorListener<T> listener)

@java.lang.Override public void addDataflowChannelListener(DataflowChannelListener<T> listener)

@java.lang.Override public void fireBindError(T oldValue, T failedValue, boolean uniqueBind)

@java.lang.Override public void fireBindError(T oldValue, java.lang.Throwable failedError)

@java.lang.Override public void fireBindError(java.lang.Throwable oldError, T failedValue, boolean uniqueBind)

@java.lang.Override public void fireBindError(java.lang.Throwable oldError, java.lang.Throwable failedError)

@java.lang.Override public void fireOnMessage(T message)

@java.lang.SuppressWarnings("ReturnOfCollectionOrArrayField") @java.lang.Override public java.util.Collection<BindErrorListener<T>> getBindErrorListeners()

@java.lang.SuppressWarnings("ReturnOfCollectionOrArrayField") @java.lang.Override public java.util.Collection<DataflowChannelListener<T>> getListeners()

@java.lang.Override public void removeBindErrorListener(BindErrorListener<T> listener)

@java.lang.Override public void removeDataflowChannelListener(DataflowChannelListener<T> listener)