org.hornetq.core.paging.impl

Class PageTransactionInfoImpl

java.lang.Object

org.hornetq.core.paging.impl.PageTransactionInfoImpl

All Implemented Interfaces:

EncodingSupport, PageTransactionInfo

public class PageTransactionInfoImpl
extends Object
implements PageTransactionInfo

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
PageTransactionInfoImpl()
PageTransactionInfoImpl(long transactionID)

Method Summary

Methods

Modifier and Type	Method and Description
void	commit()
void	decode(HornetQBuffer buffer)
boolean	deliverAfterCommit(PageSubscription cursor, PagePosition cursorPos) This method will hold the position to be delivered later in case this transaction is pending.
void	encode(HornetQBuffer buffer)
int	getEncodeSize()
int	getNumberOfMessages()
long	getRecordID()
long	getTransactionID()
void	increment(boolean persistent)
void	increment(int durableSize, int nonDurableSize)
protected org.hornetq.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperation	internalUpdatePageManager(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment)
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 recordID)
void	store(StorageManager storageManager, PagingManager pagingManager, Transaction tx)
void	storeUpdate(StorageManager storageManager, PagingManager pagingManager)
void	storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

PageTransactionInfoImpl

public PageTransactionInfoImpl(long transactionID)

PageTransactionInfoImpl

public PageTransactionInfoImpl()

Method Detail

getRecordID

public long getRecordID()

Specified by:

getRecordID in interface PageTransactionInfo

setRecordID

public void setRecordID(long recordID)

Specified by:

setRecordID in interface PageTransactionInfo

getTransactionID

public long getTransactionID()

Specified by:

getTransactionID in interface PageTransactionInfo

onUpdate

public void onUpdate(int update,
            StorageManager storageManager,
            PagingManager pagingManager)

Specified by:

onUpdate in interface PageTransactionInfo

increment

public void increment(boolean persistent)

Specified by:

increment in interface PageTransactionInfo

increment

public void increment(int durableSize,
             int nonDurableSize)

Specified by:

increment in interface PageTransactionInfo

getNumberOfMessages

public int getNumberOfMessages()

Specified by:

getNumberOfMessages in interface PageTransactionInfo

decode

public void decode(HornetQBuffer buffer)

Specified by:

decode in interface EncodingSupport

encode

public void encode(HornetQBuffer buffer)

Specified by:

encode in interface EncodingSupport

getEncodeSize

public int getEncodeSize()

Specified by:

getEncodeSize in interface EncodingSupport

commit

public void commit()

Specified by:

commit in interface PageTransactionInfo

store

public void store(StorageManager storageManager,
         PagingManager pagingManager,
         Transaction tx)
           throws Exception

Specified by:

store in interface PageTransactionInfo

Throws:

Exception

storeUpdate

public void storeUpdate(StorageManager storageManager,
               PagingManager pagingManager,
               Transaction tx)
                 throws Exception

Specified by:

storeUpdate in interface PageTransactionInfo

Throws:

Exception

reloadUpdate

public void reloadUpdate(StorageManager storageManager,
                PagingManager pagingManager,
                Transaction tx,
                int increment)
                  throws Exception

Specified by:

reloadUpdate in interface PageTransactionInfo

Throws:

Exception

internalUpdatePageManager

protected org.hornetq.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperation internalUpdatePageManager(StorageManager storageManager,
                                                                                                   PagingManager pagingManager,
                                                                                                   Transaction tx,
                                                                                                   int increment)

Parameters:

storageManager -

pagingManager -

tx -

storeUpdate

public void storeUpdate(StorageManager storageManager,
               PagingManager pagingManager)
                 throws Exception

Specified by:

storeUpdate in interface PageTransactionInfo

Throws:

Exception

isCommit

public boolean isCommit()

Specified by:

isCommit in interface PageTransactionInfo

setCommitted

public void setCommitted(boolean committed)

Specified by:

setCommitted in interface PageTransactionInfo

isRollback

public boolean isRollback()

Specified by:

isRollback in interface PageTransactionInfo

rollback

public void rollback()

Specified by:

rollback in interface PageTransactionInfo

toString

public String toString()

Overrides:

toString in class Object

deliverAfterCommit

public boolean deliverAfterCommit(PageSubscription cursor,
                         PagePosition cursorPos)

Description copied from interface: PageTransactionInfo

This method will hold the position to be delivered later in case this transaction is pending. If the tx is not pending, it will return false, so the caller can deliver it right away

Specified by:

deliverAfterCommit in interface PageTransactionInfo

Returns:

true if the message will be delivered later, false if it should be delivered right away