org.dawb.passerelle.channels
Class DataReceiverChannel

java.lang.Object
  extended by java.lang.Thread
      extended by com.isencia.message.ReceiverChannel
          extended by com.isencia.message.ReaderReceiverChannel
              extended by org.dawb.passerelle.channels.DataReceiverChannel
All Implemented Interfaces:
com.isencia.message.IReceiverChannel, java.lang.Runnable

public class DataReceiverChannel
extends com.isencia.message.ReaderReceiverChannel

DataLoaderReceiverChannel a channel for reading data sets from arbitrary data files.

Author:
gerring

Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
DataReceiverChannel(com.isencia.message.extractor.IMessageExtractor extractor)
           
 
Method Summary
 void close()
           
 void open()
           
 
Methods inherited from class com.isencia.message.ReaderReceiverChannel
getExtractor, getReader, setExtractor, setReader
 
Methods inherited from class com.isencia.message.ReceiverChannel
acceptMessage, addListener, addListeners, getListeners, getMessage, isOpen, removeListener, run, setInterceptorChainOnLeave
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

DataReceiverChannel

public DataReceiverChannel(com.isencia.message.extractor.IMessageExtractor extractor)
Method Detail

open

public void open()
          throws com.isencia.message.ChannelException
Specified by:
open in interface com.isencia.message.IReceiverChannel
Overrides:
open in class com.isencia.message.ReaderReceiverChannel
Throws:
com.isencia.message.ChannelException
See Also:
ISenderChannel.open()

close

public void close()
           throws com.isencia.message.ChannelException
Specified by:
close in interface com.isencia.message.IReceiverChannel
Overrides:
close in class com.isencia.message.ReaderReceiverChannel
Throws:
com.isencia.message.ChannelException