KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > ubermq > jms > client > msg > LocalBytesMessage


1 package com.ubermq.jms.client.msg;
2
3 import com.ubermq.jms.client.*;
4 import com.ubermq.jms.common.datagram.*;
5
6 /**
7  * A BytesMessage implementation that simply inherits stream functionality
8  * from its base class and implements the necessary JMS interface.
9  */

10 public final class LocalBytesMessage
11     extends AbstractStreamMessage
12     implements javax.jms.BytesMessage JavaDoc
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 JavaDoc
20     {
21         try
22         {
23             return super.in.available();
24         }
25         catch (java.io.IOException JavaDoc 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