com.northconcepts.datapipeline.core
Class DebugReader

java.lang.Object
  com.northconcepts.datapipeline.core.DataEndpoint
      com.northconcepts.datapipeline.core.DataReader
          com.northconcepts.datapipeline.core.ProxyReader
              com.northconcepts.datapipeline.core.DebugReader

public class DebugReader
extends ProxyReader

A proxy that prints records passing through to a stream in a human-readable format

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint

DataEndpoint.State

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint

BUFFER_SIZE, log

Constructor Summary

DebugReader(DataReader nestedDataReader, String id, OutputStream outputStream)

DebugReader(DataReader nestedDataReader, String id, Writer writer)

Method Summary

void	close() Indicates that this endpoint has finished reading or writing.
boolean	getCloseWriterOnClose()
protected Record	interceptRecord(Record record)
void	setCloseWriterOnClose(boolean closeWriterOnClose)

Methods inherited from class com.northconcepts.datapipeline.core.ProxyReader

addExceptionProperties, available, getNestedReader, open, readImpl, setNestedDataReader, setNestedDataReader

Methods inherited from class com.northconcepts.datapipeline.core.DataReader

getBufferSize, getRootReader, peek, pop, push, read, skip

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint

assertNotOpened, assertOpened, decrementRecordCount, exception, exception, exception, finalize, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, getState, incrementRecordCount, isClosed, isOpen, isRecordCountBigInteger, resetRecordCount, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

DebugReader

public DebugReader(DataReader nestedDataReader,
                   String id,
                   Writer writer)

DebugReader

public DebugReader(DataReader nestedDataReader,
                   String id,
                   OutputStream outputStream)

Method Detail

close

public void close()
           throws DataException

Description copied from class: DataEndpoint

Indicates that this endpoint has finished reading or writing.

Overrides:

close in class ProxyReader

Throws:

DataException

getCloseWriterOnClose

public boolean getCloseWriterOnClose()

setCloseWriterOnClose

public void setCloseWriterOnClose(boolean closeWriterOnClose)

interceptRecord

protected Record interceptRecord(Record record)
                          throws Throwable

Overrides:

interceptRecord in class ProxyReader

Throws:

Throwable