User: chirino
Date: 01/10/27 21:07:35
Modified: src/main/org/jboss/mq/selectors Selector.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 +10 -10 jbossmq/src/main/org/jboss/mq/selectors/Selector.java
Index: Selector.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/selectors/Selector.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- Selector.java 2001/08/24 17:27:08 1.4
+++ Selector.java 2001/10/28 04:07:35 1.5
@@ -24,7 +24,7 @@
* @author <a href="mailto:[EMAIL PROTECTED]";>Jason Dillon</a>
* @author [EMAIL PROTECTED]
* @created August 16, 2001
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
public class Selector
{
@@ -77,7 +77,7 @@
// }
}
- public boolean test(SpyMessage mes) throws JMSException
+ public boolean test(SpyMessage.Header mes) throws JMSException
{
try
{
@@ -87,7 +87,7 @@
while (i.hasNext())
{
Identifier id = (Identifier)i.next();
- Object find = mes.getObjectProperty(id.name);
+ Object find = mes.jmsProperties.get(id.name);
// if (cat.isDebugEnabled()) {
// cat.debug("Identifier: " + id);
// cat.debug("Property: " + find);
@@ -180,7 +180,7 @@
}
// [JPL]
- private Object getHeaderFieldReferences(SpyMessage msg, String idName)
+ private Object getHeaderFieldReferences(SpyMessage.Header header, String idName)
throws JMSException
{
// JMS 3.8.1.1 -- Message header field references are restricted to:
@@ -189,27 +189,27 @@
//
if (idName.equals("JMSDeliveryMode"))
{
- return new Integer(msg.getJMSDeliveryMode());
+ return new Integer(header.jmsDeliveryMode);
}
else if (idName.equals("JMSPriority"))
{
- return new Integer(msg.getJMSPriority());
+ return new Integer(header.jmsPriority);
}
else if (idName.equals("JMSMessageID"))
{
- return msg.getJMSMessageID();
+ return header.jmsMessageID;
}
else if (idName.equals("JMSTimestamp"))
{
- return new Long(msg.getJMSTimestamp());
+ return new Long(header.jmsTimeStamp);
}
else if (idName.equals("JMSCorrelationID"))
{
- return msg.getJMSCorrelationID();
+ return header.jmsCorrelationIDString;
}
else if (idName.equals("JMSType"))
{
- return msg.getJMSType();
+ return header.jmsType;
}
else
{
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
