org.jboss.messaging.core.impl
Class NullPersistenceManager

java.lang.Object
  org.jboss.messaging.core.impl.NullPersistenceManager

All Implemented Interfaces:

MessagingComponent, PersistenceManager

public class NullPersistenceManager
extends java.lang.Object
implements PersistenceManager

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.messaging.core.contract.PersistenceManager

PersistenceManager.InitialLoadInfo, PersistenceManager.MessageChannelPair, PersistenceManager.ReferenceInfo

Constructor Summary

NullPersistenceManager()

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)
int	getPeerID()
long	getTimeMark()
boolean	idExists(java.lang.String messageID)
void	initCounter(int serverPeerID, long serverStartTime)
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	setPeerID(int peerID)
void	setTimeMark(long timeMark)
void	start()
void	stop()
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 class java.lang.Object

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

Constructor Detail

NullPersistenceManager

public NullPersistenceManager()

Method Detail

addReference

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

Specified by:

addReference in interface PersistenceManager

Throws:

java.lang.Exception

getMessageChannelPairAcksForTx

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

Specified by:

getMessageChannelPairAcksForTx in interface PersistenceManager

Throws:

java.lang.Exception

getMessageChannelPairRefsForTx

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

Specified by:

getMessageChannelPairRefsForTx in interface PersistenceManager

Throws:

java.lang.Exception

getMessages

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

Specified by:

getMessages in interface PersistenceManager

Throws:

java.lang.Exception

getPagedReferenceInfos

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

Specified by:

getPagedReferenceInfos in interface PersistenceManager

Throws:

java.lang.Exception

idExists

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

Specified by:

idExists in interface PersistenceManager

Throws:

java.lang.Exception

loadFromStart

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

Specified by:

loadFromStart in interface PersistenceManager

Throws:

java.lang.Exception

mergeAndLoad

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

Specified by:

mergeAndLoad in interface PersistenceManager

Throws:

java.lang.Exception

mergeTransactions

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

Specified by:

mergeTransactions in interface PersistenceManager

Throws:

java.lang.Exception

moveReference

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

Specified by:

moveReference in interface PersistenceManager

Throws:

java.lang.Exception

pageReferences

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

Specified by:

pageReferences in interface PersistenceManager

Throws:

java.lang.Exception

removeDepagedReferences

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

Specified by:

removeDepagedReferences in interface PersistenceManager

Throws:

java.lang.Exception

removeReference

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

Specified by:

removeReference in interface PersistenceManager

Throws:

java.lang.Exception

addTransaction

public void addTransaction(Transaction tx)

Specified by:

addTransaction in interface PersistenceManager

reserveIDBlock

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

Specified by:

reserveIDBlock in interface PersistenceManager

Throws:

java.lang.Exception

retrievePreparedTransactions

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

Specified by:

retrievePreparedTransactions in interface PersistenceManager

Throws:

java.lang.Exception

updateDeliveryCount

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

Specified by:

updateDeliveryCount in interface PersistenceManager

Throws:

java.lang.Exception

updatePageOrder

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

Specified by:

updatePageOrder in interface PersistenceManager

Throws:

java.lang.Exception

updateReferencesNotPagedInRange

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

Specified by:

updateReferencesNotPagedInRange in interface PersistenceManager

Throws:

java.lang.Exception

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface MessagingComponent

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Specified by:

stop in interface MessagingComponent

Throws:

java.lang.Exception

initCounter

public void initCounter(int serverPeerID,
                        long serverStartTime)

setPeerID

public void setPeerID(int peerID)

getPeerID

public int getPeerID()

setTimeMark

public void setTimeMark(long timeMark)

getTimeMark

public long getTimeMark()