[Ubermq-commits] jms/src/com/ubermq/jms/server/datagram/impl ServerMessageDatagram.java,1.4,1.5

[<ji...@us...>]

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/server/datagram/impl
In directory sc8-pr-cvs1:/tmp/cvs-serv22791/src/com/ubermq/jms/server/datagram/impl

Modified Files:
	ServerMessageDatagram.java 
Log Message:
1. bugfix with message viewer dealing with XML
2. clustering can forward subsets of #
3. server message datagram knows how to extract the body, if so requested.


Index: ServerMessageDatagram.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/datagram/impl/ServerMessageDatagram.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** ServerMessageDatagram.java	18 Oct 2002 16:59:29 -0000	1.4
--- ServerMessageDatagram.java	7 May 2003 17:41:47 -0000	1.5
***************
*** 161,165 ****
                  return new Long(buffer.getLong(TIMESTAMP_OFFSET));
              case STDPROP_BODY:
!                 return null;
              case STDPROP_DELIVERYMODE:
                  return new Integer(MessageDatagram.getFlagBasedProperty(buffer.getLong(VARIOUS_OFFSET), MessageDatagram.DELIVERY_SHIFT, MessageDatagram.DELIVERY_MASK));
--- 161,167 ----
                  return new Long(buffer.getLong(TIMESTAMP_OFFSET));
              case STDPROP_BODY:
! 				{
! 					return readTypedData((ByteBuffer)this.buffer.duplicate().position(propsOffset + buffer.getInt(PROPS_LEN_OFFSET)));
! 				}
              case STDPROP_DELIVERYMODE:
                  return new Integer(MessageDatagram.getFlagBasedProperty(buffer.getLong(VARIOUS_OFFSET), MessageDatagram.DELIVERY_SHIFT, MessageDatagram.DELIVERY_MASK));