org.jboss.messaging.core.contract
Interface PersistenceManager

All Superinterfaces:

MessagingComponent

All Known Implementing Classes:

JDBCPersistenceManager, NullPersistenceManager

public interface PersistenceManager
extends MessagingComponent

The interface to the persistence manager.

Version:

1.1 PersistenceManager.java,v 1.1 2006/02/22 17:33:42 timfox Exp

Author:

Ovidiu Feodorov, Tim Fox, Madhu Konda, Juha Lindfors

Nested Class Summary

static class	PersistenceManager.InitialLoadInfo
static class	PersistenceManager.MessageChannelPair
static class	PersistenceManager.ReferenceInfo

Method Summary

void	addReference(long channelID, MessageReference ref, Transaction tx)
void	addTransaction(Transaction tx)
java.util.List	getMessageChannelPairAcksForTx(long transactionId)
java.util.List	getMessageChannelPairRefsForTx(long transactionId)
java.util.List	getMessages(java.util.List messageIds)
java.util.List	getPagedReferenceInfos(long channelID, long orderStart, int number)
boolean	idExists(java.lang.String messageID)
PersistenceManager.InitialLoadInfo	loadFromStart(long channelID, int fullSize)
PersistenceManager.InitialLoadInfo	mergeAndLoad(long fromChannelID, long toChannelID, int numberToLoad, long firstPagingOrder, long nextPagingOrder)
void	mergeTransactions(int fromNodeID, int toNodeID)
void	moveReference(long sourceChannelID, long destChannelID, MessageReference ref)
void	pageReferences(long channelID, java.util.List references, boolean paged)
void	removeDepagedReferences(long channelID, java.util.List refs)
void	removeReference(long channelID, MessageReference ref, Transaction tx)
long	reserveIDBlock(java.lang.String counterName, int size)
java.util.List	retrievePreparedTransactions()
void	updateDeliveryCount(long channelID, MessageReference ref)
void	updatePageOrder(long channelID, java.util.List references)
void	updateReferencesNotPagedInRange(long channelID, long orderStart, long orderEnd, long num)

Methods inherited from interface org.jboss.messaging.core.contract.MessagingComponent

start, stop

Method Detail

addReference

void addReference(long channelID,
                  MessageReference ref,
                  Transaction tx)
                  throws java.lang.Exception

Throws:

java.lang.Exception

moveReference

void moveReference(long sourceChannelID,
                   long destChannelID,
                   MessageReference ref)
                   throws java.lang.Exception

Throws:

java.lang.Exception

removeReference

void removeReference(long channelID,
                     MessageReference ref,
                     Transaction tx)
                     throws java.lang.Exception

Throws:

java.lang.Exception

updateDeliveryCount

void updateDeliveryCount(long channelID,
                         MessageReference ref)
                         throws java.lang.Exception

Throws:

java.lang.Exception

retrievePreparedTransactions

java.util.List retrievePreparedTransactions()
                                            throws java.lang.Exception

Throws:

java.lang.Exception

getMessageChannelPairRefsForTx

java.util.List getMessageChannelPairRefsForTx(long transactionId)
                                              throws java.lang.Exception

Throws:

java.lang.Exception

getMessageChannelPairAcksForTx

java.util.List getMessageChannelPairAcksForTx(long transactionId)
                                              throws java.lang.Exception

Throws:

java.lang.Exception

pageReferences

void pageReferences(long channelID,
                    java.util.List references,
                    boolean paged)
                    throws java.lang.Exception

Throws:

java.lang.Exception

removeDepagedReferences

void removeDepagedReferences(long channelID,
                             java.util.List refs)
                             throws java.lang.Exception

Throws:

java.lang.Exception

updatePageOrder

void updatePageOrder(long channelID,
                     java.util.List references)
                     throws java.lang.Exception

Throws:

java.lang.Exception

updateReferencesNotPagedInRange

void updateReferencesNotPagedInRange(long channelID,
                                     long orderStart,
                                     long orderEnd,
                                     long num)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

getPagedReferenceInfos

java.util.List getPagedReferenceInfos(long channelID,
                                      long orderStart,
                                      int number)
                                      throws java.lang.Exception

Throws:

java.lang.Exception

loadFromStart

PersistenceManager.InitialLoadInfo loadFromStart(long channelID,
                                                 int fullSize)
                                                 throws java.lang.Exception

Throws:

java.lang.Exception

mergeTransactions

void mergeTransactions(int fromNodeID,
                       int toNodeID)
                       throws java.lang.Exception

Throws:

java.lang.Exception

mergeAndLoad

PersistenceManager.InitialLoadInfo mergeAndLoad(long fromChannelID,
                                                long toChannelID,
                                                int numberToLoad,
                                                long firstPagingOrder,
                                                long nextPagingOrder)
                                                throws java.lang.Exception

Throws:

java.lang.Exception

getMessages

java.util.List getMessages(java.util.List messageIds)
                           throws java.lang.Exception

Throws:

java.lang.Exception

reserveIDBlock

long reserveIDBlock(java.lang.String counterName,
                    int size)
                    throws java.lang.Exception

Throws:

java.lang.Exception

idExists

boolean idExists(java.lang.String messageID)
                 throws java.lang.Exception

Throws:

java.lang.Exception

addTransaction

void addTransaction(Transaction tx)