Package org.apache.activemq.store.kahadb.disk.journal

Class TargetedDataFileAppender.WriteBatch

java.lang.Object

org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch

Enclosing class:

TargetedDataFileAppender

public class TargetedDataFileAppender.WriteBatch
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
DataFile	dataFile
AtomicReference<IOException>	exception
protected int	offset
int	size
LinkedNodeList<Journal.WriteCommand>	writes

Constructor Summary

Constructors

Constructor	Description
WriteBatch(DataFile dataFile, int offset)
WriteBatch(DataFile dataFile, int offset, Journal.WriteCommand write)

Method Summary

Modifier and Type	Method	Description
void	append(Journal.WriteCommand write)
boolean	canAppend(Journal.WriteCommand write)

Methods inherited from class java.lang.Object

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

Field Detail

offset

protected final int offset

dataFile

public final DataFile dataFile

writes

public final LinkedNodeList<Journal.WriteCommand> writes

size

public int size

exception

public AtomicReference<IOException> exception

Constructor Detail

WriteBatch

public WriteBatch(DataFile dataFile,
                  int offset)

WriteBatch

public WriteBatch(DataFile dataFile,
                  int offset,
                  Journal.WriteCommand write)
           throws IOException

Throws:

IOException

Method Detail

canAppend

public boolean canAppend(Journal.WriteCommand write)

append

public void append(Journal.WriteCommand write)
            throws IOException

Throws:

IOException