com.northconcepts.datapipeline.multiplex
Class DeMux

java.lang.Object
  com.northconcepts.datapipeline.multiplex.DeMux

public class DeMux
extends Object

Nested Class Summary

static class

DeMux.Strategy

Field Summary

static int

MAX_QUEUE_SIZE

Constructor Summary

DeMux(DataReader source, DeMux.Strategy strategy)

Method Summary

DataReader	createReader()
protected DeMux.Strategy	getStrategy()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_QUEUE_SIZE

public static final int MAX_QUEUE_SIZE

See Also:

Constant Field Values

Constructor Detail

DeMux

public DeMux(DataReader source,
             DeMux.Strategy strategy)

Method Detail

getStrategy

protected DeMux.Strategy getStrategy()

createReader

public DataReader createReader()

run

public void run()
         throws DataException

Throws:

DataException