biz.hammurapi.dataflow
Class DataPump.DataSinkProxy

java.lang.Object
  extended by biz.hammurapi.dataflow.DataPump.DataSinkProxy
All Implemented Interfaces:
DataSink
Enclosing class:
DataPump

protected class DataPump.DataSinkProxy
extends java.lang.Object
implements DataSink

Blocks sources when stopped.

Author:
Pavel

Constructor Summary
DataPump.DataSinkProxy(DataSink sink)
           
 
Method Summary
 boolean addData(Data data)
          Adds data to the sink.
 boolean controlsMultiplexing()
           
 DataItemInfo[] getDataInfo()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DataPump.DataSinkProxy

public DataPump.DataSinkProxy(DataSink sink)
Method Detail

addData

public boolean addData(Data data)
Description copied from interface: DataSink
Adds data to the sink.

Specified by:
addData in interface DataSink
Returns:
true if data was "consumed" and shall be removed from further processing. If this sink is attached to a multiplexor, then the multiplexor shall not continue adding given data to "sibling" sinks.

controlsMultiplexing

public boolean controlsMultiplexing()
Specified by:
controlsMultiplexing in interface DataSink
Returns:
true if this sink controls multiplexing to "sibling" sinks, i.e. if addData() can return true.

getDataInfo

public DataItemInfo[] getDataInfo()
Specified by:
getDataInfo in interface DataSink
Returns:
Information about data items expected/required by the sink.


Copyright © 2005 Hammurapi Group. All Rights Reserved.