org.agilewiki.jfile.transactions.transactionAggregator

Class TransactionAggregator

java.lang.Object

org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jfile.transactions.BlockSource

org.agilewiki.jfile.transactions.transactionAggregator.TransactionAggregator

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 TransactionAggregator
extends BlockSource

Aggregates transactions into blocks.

Nested Class Summary

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

org.agilewiki.jactor.lpc.JLPCActor.SMBuilder

Field Summary

Fields inherited from class org.agilewiki.jfile.transactions.BlockSource

blockFlowBuffer

Constructor Summary

Constructors

Constructor and Description
TransactionAggregator()

Method Summary

Methods

Modifier and Type	Method and Description
void	aggregateTransaction(String actorType, org.agilewiki.jactor.factory.ActorFactory actorFactory, byte[] bytes, org.agilewiki.jactor.RP rp)
protected Block	newBlock() Creates a new block.

Methods inherited from class org.agilewiki.jfile.transactions.BlockSource

finish, setNext

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

Constructor Detail

TransactionAggregator

public TransactionAggregator()

Method Detail

newBlock

protected Block newBlock()

Creates a new block.

Returns:

A new block.

aggregateTransaction

public void aggregateTransaction(String actorType,
                        org.agilewiki.jactor.factory.ActorFactory actorFactory,
                        byte[] bytes,
                        org.agilewiki.jactor.RP rp)
                          throws Exception

Throws:

Exception