public interface PageTransactionInfo extends EncodingSupport
Modifier and Type | Method and Description |
---|---|
void |
commit() |
boolean |
deliverAfterCommit(PageSubscription cursor,
PagePosition cursorPos)
This method will hold the position to be delivered later in case this transaction is pending.
|
int |
getNumberOfMessages() |
long |
getRecordID() |
long |
getTransactionID() |
void |
increment(int durableSize,
int nonDurableSize) |
boolean |
isCommit() |
boolean |
isRollback() |
void |
onUpdate(int update,
StorageManager storageManager,
PagingManager pagingManager) |
void |
reloadUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
rollback() |
void |
setCommitted(boolean committed) |
void |
setRecordID(long id) |
void |
store(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
void |
storeUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
decode, encode, getEncodeSize
boolean isCommit()
boolean isRollback()
void setCommitted(boolean committed)
void commit()
void rollback()
long getRecordID()
void setRecordID(long id)
long getTransactionID()
void store(StorageManager storageManager, PagingManager pagingManager, Transaction tx) throws Exception
Exception
void storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx) throws Exception
Exception
void reloadUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) throws Exception
Exception
void onUpdate(int update, StorageManager storageManager, PagingManager pagingManager)
void increment(int durableSize, int nonDurableSize)
int getNumberOfMessages()
boolean deliverAfterCommit(PageSubscription cursor, PagePosition cursorPos)
cursor
- cursorPos
- Copyright © 2018 JBoss by Red Hat. All rights reserved.