Package com.swiftmq.impl.store.standard

Class StoreTransactionImpl

java.lang.Object

com.swiftmq.impl.store.standard.StoreTransactionImpl

All Implemented Interfaces:

CacheReleaseListener

Direct Known Subclasses:

StoreReadTransactionImpl, StoreWriteTransactionImpl

public abstract class StoreTransactionImpl
extends Object
implements CacheReleaseListener

Constructor Summary

Constructors

Constructor	Description
StoreTransactionImpl(StoreContext ctx, String queueName, QueueIndex queueIndex)

Method Summary

Modifier and Type	Method	Description
void	abort()
void	abort(AsyncCompletionCallback callback)
protected void	addMessagePageReference(MessagePageReference ref)
protected boolean	checkClosedAsync(AsyncCompletionCallback callback)
protected void	close()
void	commit()
void	commit(AsyncCompletionCallback callback)
protected AsyncCompletionCallback	createLocalCallback(AsyncCompletionCallback callback)
void	releaseCache()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

StoreTransactionImpl

public StoreTransactionImpl(StoreContext ctx,
 String queueName,
 QueueIndex queueIndex)

Method Details

addMessagePageReference

protected void addMessagePageReference(MessagePageReference ref)

checkClosedAsync

protected boolean checkClosedAsync(AsyncCompletionCallback callback)

createLocalCallback

protected AsyncCompletionCallback createLocalCallback(AsyncCompletionCallback callback)

releaseCache

public void releaseCache()

Specified by:

releaseCache in interface CacheReleaseListener

commit

public void commit()
            throws StoreException

Throws:

StoreException

commit

public void commit(AsyncCompletionCallback callback)

abort

public void abort()
           throws StoreException

Throws:

StoreException

abort

public void abort(AsyncCompletionCallback callback)

close

protected void close()

toString

public String toString()

Overrides:

toString in class Object