User: hiram
Date: 01/01/10 05:57:49
Modified: src/java/org/spydermq SpyMessage.java
Log:
Feature Add: Faster recovery after a spyderMQ server failure
Feature Add: Better server scalability by moving message not in the working set to
secondary storage.
Revision Changes Path
1.13 +4 -20 spyderMQ/src/java/org/spydermq/SpyMessage.java
Index: SpyMessage.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyMessage.java,v
retrieving revision 1.12
retrieving revision 1.13
diff -u -r1.12 -r1.13
--- SpyMessage.java 2000/12/31 23:46:32 1.12
+++ SpyMessage.java 2001/01/10 13:57:47 1.13
@@ -22,10 +22,10 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.12 $
+ * @version $Revision: 1.13 $
*/
public class SpyMessage
- implements Serializable, Cloneable, Message, Comparable
+ implements Serializable, Cloneable, Message
{
// Constants -----------------------------------------------------
@@ -182,7 +182,7 @@
jmsExpiration=expiration;
}
- public int getJMSPriority() throws JMSException
+ public int getJMSPriority()
{
return jmsPriority;
}
@@ -432,23 +432,7 @@
}
- /**
- * Return a negative number if this message should be sent
- * before the o message. Return a positive if should be sent
- * after the o message.
- */
- public int compareTo(Object o) {
-
- SpyMessage sm = (SpyMessage)o;
-
- if( jmsPriority > sm.jmsPriority) {
- return -1;
- }
- if( jmsPriority < sm.jmsPriority ) {
- return 1;
- }
- return (int)(messageId - sm.messageId);
- }
+
public void doAcknowledge() throws JMSException
