Modifier and Type | Class and Description |
---|---|
static interface |
DeMux.IStrategy |
static class |
DeMux.Strategy |
Modifier and Type | Field and Description |
---|---|
protected static Record |
EOF |
static Logger |
log |
static int |
MAX_QUEUE_SIZE |
Constructor and Description |
---|
DeMux(DataReader source,
DeMux.IStrategy strategy) |
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() |
public static final Logger log
public static final int MAX_QUEUE_SIZE
protected static final Record EOF
public DeMux(DataReader source, DeMux.IStrategy strategy)
public DeMux.IStrategy getStrategy()
public DataReader getSource()
public List<com.northconcepts.datapipeline.multiplex.DeMuxReader> getSink()
public Thread getThread()
public DataReader createReader()
public void run(boolean async) throws DataException
DataException
public void runAsync() throws DataException
DataException
public void run() throws DataException
run
in interface Runnable
DataException
public void join(long millis) throws InterruptedException
InterruptedException
public void join(long millis, int nanos) throws InterruptedException
InterruptedException
public void join() throws InterruptedException
InterruptedException
public boolean isFinished()
public void stop()
protected void removeClosedSinks()
Copyright (c) 2006-2024 North Concepts Inc. All Rights Reserved.