Class StoreTransactionImpl

java.lang.Object

com.swiftmq.impl.store.standard.StoreTransactionImpl

All Implemented Interfaces:

CacheReleaseListener, com.swiftmq.swiftlet.store.StoreTransaction

Direct Known Subclasses:

StoreReadTransactionImpl, StoreWriteTransactionImpl

public abstract class StoreTransactionImpl
extends Object
implements com.swiftmq.swiftlet.store.StoreTransaction, CacheReleaseListener

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class Object

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

Methods inherited from interface com.swiftmq.swiftlet.store.StoreTransaction

abort, commit, prepare

Constructor Details

StoreTransactionImpl

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

Method Details

addMessagePageReference

protected void addMessagePageReference(MessagePageReference ref)

checkClosedAsync

protected boolean checkClosedAsync(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)

createLocalCallback

protected com.swiftmq.tools.concurrent.AsyncCompletionCallback createLocalCallback(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)

releaseCache

public void releaseCache()

Specified by:

releaseCache in interface CacheReleaseListener

commit

public void commit()
            throws com.swiftmq.swiftlet.store.StoreException

Specified by:

commit in interface com.swiftmq.swiftlet.store.StoreTransaction

Throws:

com.swiftmq.swiftlet.store.StoreException

commit

public void commit(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)

Specified by:

commit in interface com.swiftmq.swiftlet.store.StoreTransaction

abort

public void abort()
           throws com.swiftmq.swiftlet.store.StoreException

Specified by:

abort in interface com.swiftmq.swiftlet.store.StoreTransaction

Throws:

com.swiftmq.swiftlet.store.StoreException

abort

public void abort(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)

Specified by:

abort in interface com.swiftmq.swiftlet.store.StoreTransaction

close

protected void close()

toString

public String toString()

Overrides:

toString in class Object