User: chirino
Date: 01/10/27 21:07:34
Modified: src/main/org/jboss/mq/pm/jdbc MessageLog.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 +9 -9 jbossmq/src/main/org/jboss/mq/pm/jdbc/MessageLog.java
Index: MessageLog.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/jdbc/MessageLog.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- MessageLog.java 2001/09/04 15:05:16 1.4
+++ MessageLog.java 2001/10/28 04:07:34 1.5
@@ -28,7 +28,7 @@
* queue in case of provider failure.
*
* @author: Jayesh Parayali ([EMAIL PROTECTED])
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
public class MessageLog {
@@ -67,8 +67,8 @@
//Long msgId = new
Long(Long.parseLong(rs.getString(2).trim(),16));
//restore the messageId which is not persistent.
- message.messageId= Long.parseLong(rs.getString(2).trim(), 16);
- Long msgId= new Long(message.messageId);
+ message.header.messageId=
Long.parseLong(rs.getString(2).trim(), 16);
+ Long msgId= new Long(message.header.messageId);
messageIndex.put(msgId, message);
}
} catch (SQLException e) {
@@ -123,10 +123,10 @@
pstmt.setString(2, ((SpyDestination)
message.getJMSDestination()).getName());
pstmt.setBinaryStream(3, bais, messageAsBytes.length);
String hexString= null;
- if (message.messageId <= 0)
- hexString= "-" + Long.toHexString((-1) * message.messageId);
+ if (message.header.messageId <= 0)
+ hexString= "-" + Long.toHexString((-1) *
message.header.messageId);
else
- hexString= Long.toHexString(message.messageId);
+ hexString= Long.toHexString(message.header.messageId);
pstmt.setString(1, hexString);
pstmt.executeUpdate();
@@ -160,10 +160,10 @@
con= datasource.getConnection();
pstmt= con.prepareStatement("delete from jms_messages where messageid
= ? and destination = ?");
String hexString= null;
- if (message.messageId <= 0)
- hexString= "-" + Long.toHexString((-1) * message.messageId);
+ if (message.header.messageId <= 0)
+ hexString= "-" + Long.toHexString((-1) *
message.header.messageId);
else
- hexString= Long.toHexString(message.messageId);
+ hexString= Long.toHexString(message.header.messageId);
pstmt.setString(1, hexString);
pstmt.setString(2, ((SpyDestination)
message.getJMSDestination()).getName().trim());
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
