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 ([EMAIL PROTECTED])
* @author David Maplesden ([EMAIL PROTECTED])
* @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:[EMAIL PROTECTED]";>Hiram Chirino</a>
* @author <a href="mailto:[EMAIL PROTECTED]";>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
{
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
