org.apache.jackrabbit.core.journal
Class FileJournal

java.lang.Object
  org.apache.jackrabbit.core.journal.AbstractJournal
      org.apache.jackrabbit.core.journal.FileJournal

All Implemented Interfaces:

Journal

public class FileJournal
extends AbstractJournal

File-based journal implementation that appends journal records to a single file.

It is configured through the following properties:

• directory: the directory where to keep the journal file as well as the rotated files; this is a required property with no default value
• basename: the basename of journal files; the default value is DEFAULT_BASENAME
• maximumSize: the maximum size of an active journal file before rotating it: the default value is DEFAULT_MAXSIZE

Constructor Summary

FileJournal()

Method Summary

protected long	append(String producerId, InputStream in, int length) Append a record backed by a file.
void	close() Close this journal.
protected void	doLock() Lock the journal revision.
protected void	doUnlock(boolean successful) Unlock the journal revision.
String	getBasename()
String	getDirectory() Bean getters
int	getMaximumSize()
protected RecordIterator	getRecords(long startRevision) Return an iterator over all records after the specified revision.
protected long	getRevision()
void	init(String id, NamespaceResolver resolver) Initialize journal.
void	setBasename(String basename)
void	setDirectory(String directory) Bean setters
void	setMaximumSize(int maximumSize)

Methods inherited from class org.apache.jackrabbit.core.journal.AbstractJournal

createProducer, doSync, getConsumer, getId, getProducer, getResolver, lockAndSync, register, sync, unlock, unregister

Methods inherited from class java.lang.Object

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

Constructor Detail

FileJournal

public FileJournal()

Method Detail

init

public void init(String id,
                 NamespaceResolver resolver)
          throws JournalException

Initialize journal.

Specified by:

init in interface Journal

Overrides:

init in class AbstractJournal

Parameters:

id - id this journal should use to write its own records

resolver - resolver used when reading/writing records

Throws:

JournalException - if an error occurs

getRevision

protected long getRevision()
                    throws JournalException

Throws:

JournalException

getRecords

protected RecordIterator getRecords(long startRevision)
                             throws JournalException

Return an iterator over all records after the specified revision. Subclass responsibility.

Specified by:

getRecords in class AbstractJournal

Parameters:

startRevision - start point (exlusive)

Throws:

JournalException - if an error occurs

doLock

protected void doLock()
               throws JournalException

Lock the journal revision. Subclass responsibility.

Specified by:

doLock in class AbstractJournal

Throws:

JournalException - if an error occurs

append

protected long append(String producerId,
                      InputStream in,
                      int length)
               throws JournalException

Append a record backed by a file. Subclass responsibility.

Specified by:

append in class AbstractJournal

Parameters:

producerId - producer identifier

in - input stream

length - number of bytes in input stream

Returns:

the new record's revision

Throws:

JournalException - if an error occurs

doUnlock

protected void doUnlock(boolean successful)

Unlock the journal revision. Subclass responsibility.

Specified by:

doUnlock in class AbstractJournal

Parameters:

successful - flag indicating whether the update process was successful

close

public void close()

Close this journal. This should release any resources still held by this journal.

getDirectory

public String getDirectory()

Bean getters

getBasename

public String getBasename()

getMaximumSize

public int getMaximumSize()

setDirectory

public void setDirectory(String directory)

Bean setters

setBasename

public void setBasename(String basename)

setMaximumSize

public void setMaximumSize(int maximumSize)