Class CompositeStoreTransactionImpl

java.lang.Object
com.swiftmq.swiftlet.store.CompositeStoreTransaction
com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
All Implemented Interfaces:
CacheReleaseListener, com.swiftmq.swiftlet.store.StoreReadTransaction, com.swiftmq.swiftlet.store.StoreTransaction, com.swiftmq.swiftlet.store.StoreWriteTransaction

public class CompositeStoreTransactionImpl extends com.swiftmq.swiftlet.store.CompositeStoreTransaction implements CacheReleaseListener
  • Constructor Details

    • CompositeStoreTransactionImpl

      public CompositeStoreTransactionImpl(StoreContext ctx)
  • Method Details

    • setReferencable

      public void setReferencable(boolean referencable)
      Specified by:
      setReferencable in class com.swiftmq.swiftlet.store.CompositeStoreTransaction
    • isReferencable

      public boolean isReferencable()
      Specified by:
      isReferencable in class com.swiftmq.swiftlet.store.CompositeStoreTransaction
    • setMarkRedelivered

      public void setMarkRedelivered(boolean markRedelivered)
    • checkClosedAsync

      protected void 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
    • remove

      public void remove(Object key) throws com.swiftmq.swiftlet.store.StoreException
      Specified by:
      remove in interface com.swiftmq.swiftlet.store.StoreReadTransaction
      Throws:
      com.swiftmq.swiftlet.store.StoreException
    • insert

      public void insert(com.swiftmq.swiftlet.store.StoreEntry storeEntry) throws com.swiftmq.swiftlet.store.StoreException
      Specified by:
      insert in interface com.swiftmq.swiftlet.store.StoreWriteTransaction
      Throws:
      com.swiftmq.swiftlet.store.StoreException
    • prepare

      public void prepare(com.swiftmq.jms.XidImpl xid) throws com.swiftmq.swiftlet.store.StoreException
      Specified by:
      prepare in interface com.swiftmq.swiftlet.store.StoreTransaction
      Throws:
      com.swiftmq.swiftlet.store.StoreException
    • commit

      public void commit(com.swiftmq.jms.XidImpl xid) 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() 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 asyncCompletionCallback)
      Specified by:
      commit in interface com.swiftmq.swiftlet.store.StoreTransaction
    • abort

      public void abort(com.swiftmq.jms.XidImpl xid) 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() 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 asyncCompletionCallback)
      Specified by:
      abort in interface com.swiftmq.swiftlet.store.StoreTransaction
    • setPersistentStore

      public void setPersistentStore(com.swiftmq.swiftlet.store.PersistentStore persistentStore) throws com.swiftmq.swiftlet.store.StoreException
      Specified by:
      setPersistentStore in class com.swiftmq.swiftlet.store.CompositeStoreTransaction
      Throws:
      com.swiftmq.swiftlet.store.StoreException
    • commitTransaction

      public void commitTransaction() throws com.swiftmq.swiftlet.store.StoreException
      Specified by:
      commitTransaction in class com.swiftmq.swiftlet.store.CompositeStoreTransaction
      Throws:
      com.swiftmq.swiftlet.store.StoreException
    • commitTransaction

      public void commitTransaction(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
      Specified by:
      commitTransaction in class com.swiftmq.swiftlet.store.CompositeStoreTransaction
    • abortTransaction

      public void abortTransaction() throws com.swiftmq.swiftlet.store.StoreException
      Specified by:
      abortTransaction in class com.swiftmq.swiftlet.store.CompositeStoreTransaction
      Throws:
      com.swiftmq.swiftlet.store.StoreException
    • abortTransaction

      public void abortTransaction(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
      Specified by:
      abortTransaction in class com.swiftmq.swiftlet.store.CompositeStoreTransaction
    • close

      protected void close()
    • toString

      public String toString()
      Overrides:
      toString in class Object