org.jboss.messaging.core.contract
Interface PersistenceManager

All Superinterfaces:

MessagingComponent

All Known Implementing Classes:

JDBCPersistenceManager

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)
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)
PersistenceManager.InitialLoadInfo	loadFromStart(long channelID, int fullSize)
PersistenceManager.InitialLoadInfo	mergeAndLoad(long fromChannelID, long toChannelID, int numberToLoad, long firstPagingOrder, long nextPagingOrder)
void	mergeTransactions(long fromChannelID, long toChannelID)
void	pageReferences(long channelID, java.util.List references, boolean paged)
boolean	referenceExists(long messageID)
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

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(long fromChannelID,
                       long toChannelID)
                       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

referenceExists

boolean referenceExists(long messageID)
                        throws java.lang.Exception

Throws:

java.lang.Exception