org.agilewiki.jfile.transactions.logReader

Class LogReader

java.lang.Object

org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jfile.JFile

org.agilewiki.jfile.transactions.logReader.LogReader

All Implemented Interfaces:

org.agilewiki.jactor.Actor, org.agilewiki.jactor.apc.APCRequestSource, org.agilewiki.jactor.apc.RequestProcessor, org.agilewiki.jactor.lpc.RequestSource, org.agilewiki.jactor.lpc.TargetActor, Finisher

public class LogReader
extends JFile
implements Finisher

Reads a transaction log file and forwards the blocks..

Nested Class Summary

Nested classes/interfaces inherited from class org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jactor.lpc.JLPCActor.SMBuilder

Field Summary

Fields

Modifier and Type	Field and Description
long	currentPosition
int	maxSize
long	timestamp

Fields inherited from class org.agilewiki.jfile.JFile

fileChannel, metaData

Constructor Summary

Constructors

Constructor and Description
LogReader()

Method Summary

Methods

Modifier and Type	Method and Description
void	finish(org.agilewiki.jactor.RP rp)
protected Block	newBlock() Creates a new block.
void	readLog(org.agilewiki.jactor.RP rp)
void	setNext(BlockProcessor nextInPipeline) Creates a buffered connection to the block processor that is next in the pipeline.

Methods inherited from class org.agilewiki.jfile.JFile

close, forceBeforeWriteRootJid, forcedWriteRootJid, forceRootJid, getFileName, open, open, readRootJid, writeRootJid

Methods inherited from class org.agilewiki.jactor.lpc.JLPCActor

acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.agilewiki.jactor.lpc.TargetActor

setExceptionHandler

Methods inherited from interface org.agilewiki.jactor.Actor

acceptEvent, acceptRequest, getActorType, getAncestor, getFactory, getMailbox, getMatch, getParent, hasDataItem, setInitialBufferCapacity

Field Detail

currentPosition

public long currentPosition

maxSize

public int maxSize

timestamp

public long timestamp

Constructor Detail

LogReader

public LogReader()

Method Detail

newBlock

protected Block newBlock()

Creates a new block.

Returns:

A new block.

setNext

public void setNext(BlockProcessor nextInPipeline)
             throws Exception

Creates a buffered connection to the block processor that is next in the pipeline.

Parameters:

nextInPipeline - The next block processor in the pipeline.

Throws:

Exception

readLog

public void readLog(org.agilewiki.jactor.RP rp)
             throws Exception

Throws:

Exception

finish

public void finish(org.agilewiki.jactor.RP rp)
            throws Exception

Specified by:

finish in interface Finisher

Throws:

Exception