com.servingxml.components.recordio
Class MultipleRecordFilter

java.lang.Object
  extended by com.servingxml.components.recordio.MultipleRecordFilter
All Implemented Interfaces:
RecordFilter, RecordFilterChain, RecordReader, RecordWriter

public class MultipleRecordFilter
extends java.lang.Object
implements RecordFilter, RecordFilterChain


Nested Class Summary
 
Nested classes/interfaces inherited from interface com.servingxml.components.recordio.RecordReader
RecordReader.NullRecordReader
 
Nested classes/interfaces inherited from interface com.servingxml.components.recordio.RecordWriter
RecordWriter.DefaultDiscardWriter, RecordWriter.NullRecordWriter
 
Field Summary
 
Fields inherited from interface com.servingxml.components.recordio.RecordFilter
NULL
 
Fields inherited from interface com.servingxml.components.recordio.RecordWriter
DEFAULT_DISCARD_WRITER
 
Constructor Summary
MultipleRecordFilter()
           
 
Method Summary
 void addExpirable(Expirable expirable)
           
 void addRecordFilter(RecordFilter recordFilter)
           
 void close()
           
 void discardRecord(ServiceContext context, Flow flow, ServingXmlException e)
           
 void endRecordStream(ServiceContext context, Flow flow)
           
 RecordWriter getDiscardWriter()
           
 Expirable getExpirable()
           
 Key getKey()
           
 RecordWriter getRecordWriter()
           
 void readRecords(ServiceContext context, Flow flow)
           
 void setDiscardWriter(RecordWriter discardWriter)
           
 void setRecordReader(RecordReader recordReader)
           
 void setRecordWriter(RecordWriter recordWriter)
           
 void startRecordStream(ServiceContext context, Flow flow)
           
 void writeRecord(ServiceContext context, Flow flow)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MultipleRecordFilter

public MultipleRecordFilter()
Method Detail

addRecordFilter

public void addRecordFilter(RecordFilter recordFilter)
Specified by:
addRecordFilter in interface RecordFilterChain

addExpirable

public void addExpirable(Expirable expirable)
Specified by:
addExpirable in interface RecordFilterChain

setRecordReader

public void setRecordReader(RecordReader recordReader)
Specified by:
setRecordReader in interface RecordFilter

readRecords

public void readRecords(ServiceContext context,
                        Flow flow)
Specified by:
readRecords in interface RecordReader

getKey

public final Key getKey()
Specified by:
getKey in interface RecordReader

getExpirable

public final Expirable getExpirable()
Specified by:
getExpirable in interface RecordReader

getRecordWriter

public final RecordWriter getRecordWriter()
Specified by:
getRecordWriter in interface RecordReader

setRecordWriter

public final void setRecordWriter(RecordWriter recordWriter)
Specified by:
setRecordWriter in interface RecordReader

getDiscardWriter

public final RecordWriter getDiscardWriter()
Specified by:
getDiscardWriter in interface RecordReader

setDiscardWriter

public final void setDiscardWriter(RecordWriter discardWriter)
Specified by:
setDiscardWriter in interface RecordFilterChain
Specified by:
setDiscardWriter in interface RecordReader

startRecordStream

public void startRecordStream(ServiceContext context,
                              Flow flow)
Specified by:
startRecordStream in interface RecordWriter

endRecordStream

public void endRecordStream(ServiceContext context,
                            Flow flow)
Specified by:
endRecordStream in interface RecordWriter

writeRecord

public void writeRecord(ServiceContext context,
                        Flow flow)
Specified by:
writeRecord in interface RecordWriter

close

public void close()
Specified by:
close in interface RecordWriter

discardRecord

public void discardRecord(ServiceContext context,
                          Flow flow,
                          ServingXmlException e)
Specified by:
discardRecord in interface RecordReader