Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.dataflow.impl
[Java] Class DataflowChannelEventOrchestrator

java.lang.Object
  groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator
All Implemented Interfaces:
BindErrorDistributor, BindErrorListenerManager, DataflowChannelEventDistributor, DataflowChannelEventListenerManager
public final class DataflowChannelEventOrchestrator

Groups the listener-related functionality shared by dataflow channels

Authors:
Vaclav Pech

Field Summary
private java.util.Collection BindErrorListener

private java.util.Collection listeners

 
Constructor Summary
DataflowChannelEventOrchestrator()

 
Method Summary
void addAllBindErrorListeners(java.util.Collection listeners)

void addAllDataflowChannelListeners(java.util.Collection listeners)

void addBindErrorListener(BindErrorListener listener)

void addDataflowChannelListener(DataflowChannelListener listener)

void fireBindError(java.lang.Object oldValue, java.lang.Object failedValue, boolean uniqueBind)

Notifies all listeners about failed bindError operations
void fireBindError(java.lang.Object oldValue, java.lang.Throwable failedError)

Notifies all listeners about failed bind operations
void fireBindError(java.lang.Throwable oldError, java.lang.Object failedValue, boolean uniqueBind)

Notifies all listeners about failed bindError operations
void fireBindError(java.lang.Throwable oldError, java.lang.Throwable failedError)

void fireOnMessage(java.lang.Object message)

java.util.Collection getBindErrorListeners()

java.util.Collection getListeners()

void removeBindErrorListener(BindErrorListener listener)

void removeDataflowChannelListener(DataflowChannelListener listener)

 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), 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

BindErrorListener

private final java.util.Collection BindErrorListener

listeners

private final java.util.Collection listeners

 
Constructor Detail

DataflowChannelEventOrchestrator

DataflowChannelEventOrchestrator()

 
Method Detail

addAllBindErrorListeners

@java.lang.Override
public void addAllBindErrorListeners(java.util.Collection listeners)

addAllDataflowChannelListeners

@java.lang.Override
public void addAllDataflowChannelListeners(java.util.Collection listeners)

addBindErrorListener

@java.lang.Override@SuppressWarnings("ReturnOfCollectionOrArrayField")
public void addBindErrorListener(BindErrorListener listener)

addDataflowChannelListener

@java.lang.Override@SuppressWarnings("ReturnOfCollectionOrArrayField")
public void addDataflowChannelListener(DataflowChannelListener listener)

fireBindError

@java.lang.Overridefor (final BindErrorListener listener : BindErrorListener) {
public void fireBindError(java.lang.Object oldValue, java.lang.Object failedValue, boolean uniqueBind)
Notifies all listeners about failed bindError operations
Parameters:
oldValue - The already bound value
failedError - The error attempted to be bound

fireBindError

@java.lang.Overridepublic void fireBindError(final Throwable oldError, final T failedValue, final boolean uniqueBind) {
public void fireBindError(java.lang.Object oldValue, java.lang.Throwable failedError)
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

fireBindError

@java.lang.Overridefor (final BindErrorListener listener : BindErrorListener) {
public void fireBindError(java.lang.Throwable oldError, java.lang.Object failedValue, boolean uniqueBind)
Notifies all listeners about failed bindError operations
Parameters:
oldError - The already bound Throwable
failedError - The error attempted to be bound

fireBindError

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

fireOnMessage

@java.lang.Override}
public void fireOnMessage(java.lang.Object message)

getBindErrorListeners

@java.lang.SuppressWarningsfor (final BindErrorListener listener : BindErrorListener) {
@java.lang.Overridelistener.onBindError(oldValue, failedValue, uniqueBind);
public java.util.Collection getBindErrorListeners()

getListeners

@java.lang.SuppressWarningsBindErrorListener.add(listener);
@java.lang.Override}
public java.util.Collection getListeners()

removeBindErrorListener

@java.lang.Override* @param failedValue The value attempted to be bound
public void removeBindErrorListener(BindErrorListener listener)

removeDataflowChannelListener

@java.lang.Override}
public void removeDataflowChannelListener(DataflowChannelListener listener)

 

Copyright © 2008–2013 Václav Pech. All Rights Reserved.