KickJava   Java API By Example, From Geeks To Geeks.

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


1 package com.ubermq.jms.client.msg;
2
3 import com.ubermq.jms.client.*;
4 import com.ubermq.jms.common.datagram.*;
5 import java.io.*;
6 import javax.jms.*;
7
8 /**
9  * A JMS StreamMessage provides a way to read and write information
10  * to a message in a stream oriented way. This adds String and Object
11  * as first-class streamable types.
12  */
13 public final class LocalStreamMessage
14     extends AbstractStreamMessage
15     implements javax.jms.StreamMessage JavaDoc
16 {
17     public LocalStreamMessage(IMessageDatagram md, IAcknowledgeHandler a) {super(md, a);}
18     public LocalStreamMessage(IMessageDatagramFactory f) {super(f);}
19
20     public int getMessageType() {return com.ubermq.jms.client.impl.LocalMessage.MSGTYPE_STREAM;}
21
22     public Object JavaDoc readObject() throws javax.jms.JMSException JavaDoc {
23         try {
24             ObjectInputStream ois = new ObjectInputStream(this.in);
25             return ois.readObject();
26         }
27         catch(Exception JavaDoc iox) {throw new javax.jms.JMSException JavaDoc(iox.toString());}
28     }
29
30     public String JavaDoc readString() throws javax.jms.JMSException JavaDoc {
31         return this.readUTF();
32     }
33
34     public void writeString(String JavaDoc str) throws javax.jms.JMSException JavaDoc {
35         if (!isWriteable())
36             throw new MessageNotWriteableException("not writeable");
37
38         this.writeUTF(str);
39     }
40 }
41
Popular Tags