Class BufferedRecordPipe

java.lang.Object

com.kingsrook.qqq.backend.core.actions.reporting.RecordPipe

com.kingsrook.qqq.backend.core.actions.reporting.BufferedRecordPipe

Direct Known Subclasses:

RecordPipeBufferedWrapper

public class BufferedRecordPipe
extends RecordPipe

Subclass of RecordPipe, which uses a buffer in the addRecord method, to avoid sending single-records at a time through postRecordActions and to consumers.

Constructor Summary

Constructors

Constructor	Description
BufferedRecordPipe()	Constructor - uses default buffer size
BufferedRecordPipe(Integer bufferSize)	Constructor - customize buffer size.

Method Summary

Modifier and Type	Method	Description
void	addRecord(QRecord record)	Add a record to the pipe.
void	finalFlush()

Methods inherited from class com.kingsrook.qqq.backend.core.actions.reporting.RecordPipe

addRecords, consumeAvailableRecords, countAvailableRecords, getCapacity, setPostRecordActions, terminate

Methods inherited from class java.lang.Object

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

Constructor Details

BufferedRecordPipe

public BufferedRecordPipe()

Constructor - uses default buffer size

BufferedRecordPipe

public BufferedRecordPipe(Integer bufferSize)

Constructor - customize buffer size.

Method Details

addRecord

public void addRecord(QRecord record)
               throws QException

Description copied from class: RecordPipe

Add a record to the pipe. Will block if the pipe is full. Will noop if pipe is terminated.

Overrides:

addRecord in class RecordPipe

Throws:

QException

finalFlush

public void finalFlush()
                throws QException

Throws:

QException