User: chirino
Date: 01/10/27 21:07:34
Modified: src/main/org/jboss/mq/pm/file MessageLog.java
PersistenceManager.java
Log:
Reorganized the JMS message headers into a Header object so that the MessageCahe can
drop the message body from memory, but keep the headers.
Also fixed a bug witht he Browse() that was introduced with the message cache.
Revision Changes Path
1.5 +3 -3 jbossmq/src/main/org/jboss/mq/pm/file/MessageLog.java
Index: MessageLog.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/file/MessageLog.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- MessageLog.java 2001/10/28 01:27:00 1.4
+++ MessageLog.java 2001/10/28 04:07:34 1.5
@@ -26,7 +26,7 @@
*
* @created August 16, 2001
* @author: Paul Kendall ([EMAIL PROTECTED])
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
public class MessageLog {
@@ -185,7 +185,7 @@
protected void writeMessageToFile( SpyMessage message, File file )
throws IOException {
ObjectOutputStream out = new ObjectOutputStream( new FileOutputStream( file )
);
- out.writeLong( message.messageId );
+ out.writeLong( message.header.messageId );
if ( message instanceof SpyEncapsulatedMessage ) {
out.writeByte( ENCAP_MESS );
} else if ( message instanceof SpyObjectMessage ) {
@@ -236,7 +236,7 @@
}
message.readExternal( in );
in.close();
- message.messageId = msgId;
+ message.header.messageId = msgId;
MessageReference mr = JMSServer.getInstance().getMessageCache().add(message);
mr.persistData = file;
1.8 +2 -2 jbossmq/src/main/org/jboss/mq/pm/file/PersistenceManager.java
Index: PersistenceManager.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/file/PersistenceManager.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -u -r1.7 -r1.8
--- PersistenceManager.java 2001/10/28 01:27:00 1.7
+++ PersistenceManager.java 2001/10/28 04:07:34 1.8
@@ -37,7 +37,7 @@
* persistence.
*
* @author Paul Kendall ([EMAIL PROTECTED])
- * @version $Revision: 1.7 $
+ * @version $Revision: 1.8 $
*/
public class PersistenceManager extends ServiceMBeanSupport implements
PersistenceManagerMBean, org.jboss.mq.pm.PersistenceManager
{
@@ -203,7 +203,7 @@
if (logInfo.destination instanceof org.jboss.mq.SpyTopic)
{
SpyMessage m = rebuild[i].getMessage();
- m.durableSubscriberID =
((org.jboss.mq.SpyTopic)logInfo.destination).getDurableSubscriptionID();
+ m.header.durableSubscriberID =
((org.jboss.mq.SpyTopic)logInfo.destination).getDurableSubscriptionID();
rebuild[i].invalidate(); // since we did an update.
}
q.restoreMessage(rebuild[i]);
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
