com.northconcepts.datapipeline.multiplex

Class DeMux

java.lang.Object

com.northconcepts.datapipeline.multiplex.DeMux

All Implemented Interfaces:

Runnable

public class DeMux
extends Object
implements Runnable

Converts a single source DataReader into many using one of the provided strategies.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DeMux.IStrategy
static class	DeMux.Strategy

Field Summary

Fields

Modifier and Type	Field and Description
protected static Record	EOF
static Logger	log
static int	MAX_QUEUE_SIZE

Constructor Summary

Constructors

Constructor and Description
DeMux(DataReader source, DeMux.IStrategy strategy)

Method Summary

Modifier and Type	Method and Description
DataReader	createReader()
List<com.northconcepts.datapipeline.multiplex.DeMuxReader>	getSink()
DataReader	getSource()
DeMux.IStrategy	getStrategy()
Thread	getThread()
boolean	isFinished()
void	join() Waits for the feeder process to finish reading records from the source reader and sending them to downstream readers.
void	join(long millis) Waits at most millis milliseconds for the feeder process to finish reading records from the source reader and sending them to downstream readers.
void	join(long millis, int nanos) Waits at most millis milliseconds plus nanos nanoseconds for the feeder process to finish reading records from the source reader and sending them to downstream readers.
protected void	removeClosedSinks()
void	run() Runs the feeder process in the current thread.
void	run(boolean async) Runs the feeder process in the current thread (false) or in a new thread (true).
void	runAsync() Runs the feeder process in a new thread.
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

log

public static final Logger log

MAX_QUEUE_SIZE

public static final int MAX_QUEUE_SIZE

See Also:

Constant Field Values

EOF

protected static final Record EOF

Constructor Detail

DeMux

public DeMux(DataReader source,
             DeMux.IStrategy strategy)

Method Detail

getStrategy

public DeMux.IStrategy getStrategy()

getSource

public DataReader getSource()

getSink

public List<com.northconcepts.datapipeline.multiplex.DeMuxReader> getSink()

getThread

public Thread getThread()

createReader

public DataReader createReader()

run

public void run(boolean async)
         throws DataException

Runs the feeder process in the current thread (false) or in a new thread (true). If true, this method blocks until all data is read in from the source reader and sent to the downstream readers.

Throws:

DataException

runAsync

public void runAsync()
              throws DataException

Runs the feeder process in a new thread. This method does not block.

Throws:

DataException

run

public void run()
         throws DataException

Runs the feeder process in the current thread. This method blocks until all data is read in from the source reader and sent to the downstream readers.

Specified by:

run in interface Runnable

Throws:

DataException

join

public void join(long millis)
          throws InterruptedException

Waits at most millis milliseconds for the feeder process to finish reading records from the source reader and sending them to downstream readers. A timeout of 0 means to wait forever.

Throws:

InterruptedException

join

public void join(long millis,
                 int nanos)
          throws InterruptedException

Waits at most millis milliseconds plus nanos nanoseconds for the feeder process to finish reading records from the source reader and sending them to downstream readers. A timeout of 0 means to wait forever.

Throws:

InterruptedException

join

public void join()
          throws InterruptedException

Waits for the feeder process to finish reading records from the source reader and sending them to downstream readers. A timeout of 0 means to wait forever.

Throws:

InterruptedException

isFinished

public boolean isFinished()

stop

public void stop()

removeClosedSinks

protected void removeClosedSinks()