From: Hiram C. <ch...@us...> - 2002-03-28 03:08:06
|
User: chirino Date: 02/03/27 19:08:05 Modified: src/main/org/jboss/mq/server JMSDestination.java MessageReference.java Log: Adding a new JDBC PersistenceManager/CacheStore. Better than the original: - does not need the NoTransDS anymore. - All SQL statements are configurable - Supports restoring the same queue multiple times. (for when the queue is deployed<->undeployed) - Easier on memory usage. - CacheManager does not store messages that are alleady stored in the DB. All that's left is more testing! Revision Changes Path 1.9 +2 -2 jbossmq/src/main/org/jboss/mq/server/JMSDestination.java Index: JMSDestination.java =================================================================== RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/JMSDestination.java,v retrieving revision 1.8 retrieving revision 1.9 diff -u -r1.8 -r1.9 --- JMSDestination.java 9 Mar 2002 15:32:34 -0000 1.8 +++ JMSDestination.java 28 Mar 2002 03:08:05 -0000 1.9 @@ -30,7 +30,7 @@ * @author Hiram Chirino (Coj...@ho...) * @author David Maplesden (Dav...@or...) * @created August 16, 2001 - * @version $Revision: 1.8 $ + * @version $Revision: 1.9 $ */ public abstract class JMSDestination { @@ -42,7 +42,7 @@ JMSServer server; //Counter used to number incomming messages. (Used to order the messages.) - long messageIdCounter = Long.MIN_VALUE; + long messageIdCounter = 0; Logger cat; 1.9 +12 -2 jbossmq/src/main/org/jboss/mq/server/MessageReference.java Index: MessageReference.java =================================================================== RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/MessageReference.java,v retrieving revision 1.8 retrieving revision 1.9 diff -u -r1.8 -r1.9 --- MessageReference.java 17 Feb 2002 17:55:08 -0000 1.8 +++ MessageReference.java 28 Mar 2002 03:08:05 -0000 1.9 @@ -26,7 +26,7 @@ * * @author <a href="mailto:hir...@jb...">Hiram Chirino</a> * @author <a href="mailto:pr...@ti...">Peter Antman</a> - * @version $Revision: 1.8 $ + * @version $Revision: 1.9 $ */ public class MessageReference implements Comparable { @@ -46,7 +46,7 @@ public MessageCache messageCache; public SpyMessage hardReference; public MessageSoftReference softReference; - boolean isStored; + public boolean isStored; // These fields are copied over from the messae itself.. // they are used too often to not have them handy. @@ -175,6 +175,16 @@ log.trace("makeSoft lock released"); } } + + public void setStored(Object persistData) throws JMSException + { + // Called from A PeristenceManager/CacheStore, + // to let us know that this message is allread stored on disk. + this.persistData = persistData; + isStored = true; + + } + void makeHard() throws JMSException { |