Package com.swiftmq.impl.store.standard

Class CompositeStoreTransactionImpl

java.lang.Object
CompositeStoreTransaction
com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
All Implemented Interfaces:
CacheReleaseListener
public class CompositeStoreTransactionImpl extends CompositeStoreTransaction implements CacheReleaseListener

  • Constructor Details

    • CompositeStoreTransactionImpl

      public CompositeStoreTransactionImpl(StoreContext ctx)

  • Method Details

    • setReferencable

      public void setReferencable(boolean referencable)

    • isReferencable

      public boolean isReferencable()

    • setMarkRedelivered

      public void setMarkRedelivered(boolean markRedelivered)

    • checkClosedAsync

      protected void checkClosedAsync(AsyncCompletionCallback callback)

    • createLocalCallback

      protected AsyncCompletionCallback createLocalCallback(AsyncCompletionCallback callback)

    • releaseCache

      public void releaseCache()
      Specified by:
      releaseCache in interface CacheReleaseListener

    • remove

      public void remove(Object key) throws StoreException
      Throws:
      StoreException

    • insert

      public void insert(StoreEntry storeEntry) throws StoreException
      Throws:
      StoreException

    • prepare

      public void prepare(XidImpl xid) throws StoreException
      Throws:
      StoreException

    • commit

      public void commit(XidImpl xid) throws StoreException
      Throws:
      StoreException

    • commit

      public void commit() throws StoreException
      Throws:
      StoreException

    • commit

      public void commit(AsyncCompletionCallback asyncCompletionCallback)

    • abort

      public void abort(XidImpl xid) throws StoreException
      Throws:
      StoreException

    • abort

      public void abort() throws StoreException
      Throws:
      StoreException

    • abort

      public void abort(AsyncCompletionCallback asyncCompletionCallback)

    • setPersistentStore

      public void setPersistentStore(PersistentStore persistentStore) throws StoreException
      Throws:
      StoreException

    • commitTransaction

      public void commitTransaction() throws StoreException
      Throws:
      StoreException

    • commitTransaction

      public void commitTransaction(AsyncCompletionCallback callback)

    • abortTransaction

      public void abortTransaction() throws StoreException
      Throws:
      StoreException

    • abortTransaction

      public void abortTransaction(AsyncCompletionCallback callback)

    • close

      protected void close()

    • toString

      public String toString()