Package com.swiftmq.impl.store.standard.xa

Class PreparedLogQueue

java.lang.Object

com.swiftmq.impl.store.standard.xa.PreparedLog

com.swiftmq.impl.store.standard.xa.PreparedLogQueue

All Implemented Interfaces:

CacheReleaseListener

public class PreparedLogQueue
extends PreparedLog
implements CacheReleaseListener

Constructor Summary

Constructors

Constructor	Description
PreparedLogQueue(StoreContext ctx, QueueIndex queueIndex)

Method Summary

Modifier and Type	Method	Description
long	add(PrepareLogRecordImpl logRecord)
void	backup(String destPath)
boolean	backupRequired()
PrepareLogRecordImpl	get(long address)
List	getAll()
void	releaseCache()
void	remove(PrepareLogRecordImpl logRecord)
String	toString()

Methods inherited from class com.swiftmq.impl.store.standard.xa.PreparedLog

getPreparedXids, getQueuesForXid

Methods inherited from class java.lang.Object

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

Constructor Details

PreparedLogQueue

public PreparedLogQueue(StoreContext ctx,
 QueueIndex queueIndex)
                 throws Exception

Throws:

Exception

Method Details

releaseCache

public void releaseCache()

Specified by:

releaseCache in interface CacheReleaseListener

add

public long add(PrepareLogRecordImpl logRecord)
         throws IOException

Specified by:

add in class PreparedLog

Throws:

IOException

get

public PrepareLogRecordImpl get(long address)
                         throws IOException

Specified by:

get in class PreparedLog

Throws:

IOException

getAll

public List getAll()
            throws IOException

Specified by:

getAll in class PreparedLog

Throws:

IOException

remove

public void remove(PrepareLogRecordImpl logRecord)
            throws IOException

Specified by:

remove in class PreparedLog

Throws:

IOException

backupRequired

public boolean backupRequired()

Specified by:

backupRequired in class PreparedLog

backup

public void backup(String destPath)
            throws Exception

Specified by:

backup in class PreparedLog

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object