User: chirino
Date: 01/10/27 21:07:35
Modified: src/main/org/jboss/mq/pm/logged SpyMessageLog.java
SpyMessageLogTester.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.4 +4 -4 jbossmq/src/main/org/jboss/mq/pm/logged/SpyMessageLog.java
Index: SpyMessageLog.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/logged/SpyMessageLog.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- SpyMessageLog.java 2001/09/06 21:49:43 1.3
+++ SpyMessageLog.java 2001/10/28 04:07:35 1.4
@@ -21,7 +21,7 @@
*
* @created August 16, 2001
* @author: Hiram Chirino ([EMAIL PROTECTED])
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class SpyMessageLog {
@@ -73,7 +73,7 @@
if ( o instanceof MessageAddedRecord ) {
MessageAddedRecord r = ( MessageAddedRecord )o;
- r.message.messageId = r.messageId;
+ r.message.header.messageId = r.messageId;
if ( r.isTransacted && !commited.contains( new Long( r.transactionId
) ) ) {
// the TX this message was part of was not
@@ -115,7 +115,7 @@
try {
messageAddedRecord.message = message;
- messageAddedRecord.messageId = message.messageId;
+ messageAddedRecord.messageId = message.header.messageId;
if ( transactionId == null ) {
messageAddedRecord.isTransacted = false;
} else {
@@ -136,7 +136,7 @@
throws JMSException {
try {
- messageRemovedRecord.messageId = message.messageId;
+ messageRemovedRecord.messageId = message.header.messageId;
if ( transactionId == null ) {
messageRemovedRecord.isTransacted = false;
} else {
1.4 +6 -6 jbossmq/src/main/org/jboss/mq/pm/logged/SpyMessageLogTester.java
Index: SpyMessageLogTester.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/logged/SpyMessageLogTester.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- SpyMessageLogTester.java 2001/09/07 02:10:37 1.3
+++ SpyMessageLogTester.java 2001/10/28 04:07:35 1.4
@@ -13,7 +13,7 @@
*
* @created August 16, 2001
* @author: Hiram Chirino ([EMAIL PROTECTED])
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class SpyMessageLogTester {
@@ -38,7 +38,7 @@
long maxMessageId = 0;
for ( int i = 0; i < queue.length; i++ ) {
System.out.println( " #" + i + ": " + queue[i] );
- maxMessageId = Math.max( maxMessageId, queue[i].messageId );
+ maxMessageId = Math.max( maxMessageId, queue[i].header.messageId );
}
org.jboss.mq.pm.Tx tx1 = tm.createTx();
@@ -72,8 +72,8 @@
throws Exception {
SpyTextMessage m = new SpyTextMessage();
- m.messageId = messageId;
- m.setText( "Hello World #" + m.messageId );
+ m.header.messageId = messageId;
+ m.setText( "Hello World #" + m.header.messageId );
System.out.println( "Adding message: " + m + ",tx=" + txid );
log.add( m, txid );
@@ -83,8 +83,8 @@
throws Exception {
SpyTextMessage m = new SpyTextMessage();
- m.messageId = messageId;
- m.setText( "Hello World #" + m.messageId );
+ m.header.messageId = messageId;
+ m.setText( "Hello World #" + m.header.messageId );
System.out.println( "Removing message: " + m + ", tx=" + txid );
log.remove( m, txid );
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
