1 package com.ubermq.jms.client.msg; 2 3 import com.ubermq.jms.client.*; 4 import com.ubermq.jms.common.datagram.*; 5 6 10 public final class LocalBytesMessage 11 extends AbstractStreamMessage 12 implements javax.jms.BytesMessage 13 { 14 public LocalBytesMessage(IMessageDatagram md, IAcknowledgeHandler a) { 15 super(md, a); 16 } 17 public LocalBytesMessage(IMessageDatagramFactory f) {super(f);} 18 19 public long getBodyLength() throws javax.jms.JMSException 20 { 21 try 22 { 23 return super.in.available(); 24 } 25 catch (java.io.IOException e) { 26 throw new JMSIOException(e); 27 } 28 } 29 30 public int getMessageType() {return com.ubermq.jms.client.impl.LocalMessage.MSGTYPE_BYTES;} 31 } 32 | Popular Tags |