org.apache.activemq.kaha.impl.async

Class JournalFacade

java.lang.Object

org.apache.activemq.kaha.impl.async.JournalFacade

All Implemented Interfaces:

org.apache.activeio.journal.Journal

public final class JournalFacade
extends java.lang.Object
implements org.apache.activeio.journal.Journal

Provides a Journal Facade to the DataManager.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JournalFacade.RecordLocationFacade

Constructor Summary

Constructors

Constructor and Description
JournalFacade(AsyncDataManager dataManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.activeio.journal.RecordLocation	getMark()
org.apache.activeio.journal.RecordLocation	getNextRecordLocation(org.apache.activeio.journal.RecordLocation location)
org.apache.activeio.packet.Packet	read(org.apache.activeio.journal.RecordLocation location)
void	setJournalEventListener(org.apache.activeio.journal.JournalEventListener listener)
void	setMark(org.apache.activeio.journal.RecordLocation location, boolean sync)
org.apache.activeio.journal.RecordLocation	write(org.apache.activeio.packet.Packet packet, boolean sync)
org.apache.activeio.journal.RecordLocation	write(org.apache.activeio.packet.Packet packet, java.lang.Runnable onComplete)

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalFacade

public JournalFacade(AsyncDataManager dataManager)

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface org.apache.activeio.journal.Journal

Throws:

java.io.IOException

getMark

public org.apache.activeio.journal.RecordLocation getMark()
                                                   throws java.lang.IllegalStateException

Specified by:

getMark in interface org.apache.activeio.journal.Journal

Throws:

java.lang.IllegalStateException

getNextRecordLocation

public org.apache.activeio.journal.RecordLocation getNextRecordLocation(org.apache.activeio.journal.RecordLocation location)
                                                                 throws org.apache.activeio.journal.InvalidRecordLocationException,
                                                                        java.io.IOException,
                                                                        java.lang.IllegalStateException

Specified by:

getNextRecordLocation in interface org.apache.activeio.journal.Journal

Throws:

org.apache.activeio.journal.InvalidRecordLocationException

java.io.IOException

java.lang.IllegalStateException

read

public org.apache.activeio.packet.Packet read(org.apache.activeio.journal.RecordLocation location)
                                       throws org.apache.activeio.journal.InvalidRecordLocationException,
                                              java.io.IOException,
                                              java.lang.IllegalStateException

Specified by:

read in interface org.apache.activeio.journal.Journal

Throws:

org.apache.activeio.journal.InvalidRecordLocationException

java.io.IOException

java.lang.IllegalStateException

setJournalEventListener

public void setJournalEventListener(org.apache.activeio.journal.JournalEventListener listener)
                             throws java.lang.IllegalStateException

Specified by:

setJournalEventListener in interface org.apache.activeio.journal.Journal

Throws:

java.lang.IllegalStateException

setMark

public void setMark(org.apache.activeio.journal.RecordLocation location,
           boolean sync)
             throws org.apache.activeio.journal.InvalidRecordLocationException,
                    java.io.IOException,
                    java.lang.IllegalStateException

Specified by:

setMark in interface org.apache.activeio.journal.Journal

Throws:

org.apache.activeio.journal.InvalidRecordLocationException

java.io.IOException

java.lang.IllegalStateException

write

public org.apache.activeio.journal.RecordLocation write(org.apache.activeio.packet.Packet packet,
                                               boolean sync)
                                                 throws java.io.IOException,
                                                        java.lang.IllegalStateException

Specified by:

write in interface org.apache.activeio.journal.Journal

Throws:

java.io.IOException

java.lang.IllegalStateException

write

public org.apache.activeio.journal.RecordLocation write(org.apache.activeio.packet.Packet packet,
                                               java.lang.Runnable onComplete)
                                                 throws java.io.IOException,
                                                        java.lang.IllegalStateException

Throws:

java.io.IOException

java.lang.IllegalStateException