KickJava   Java API By Example, From Geeks To Geeks.

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


1 package com.ubermq.jms.client.msg;
2 import com.ubermq.jms.client.*;
3 import com.ubermq.jms.client.impl.*;
4 import com.ubermq.jms.common.datagram.*;
5 import javax.jms.*;
6
7 /**
8  * An ObjectMessage contains a single Java object and writes it to
9  * the body field using Java serialization.
10  * <P>
11  * @author james
12  */
13 public final class LocalObjectMessage
14     extends LocalMessage
15     implements javax.jms.ObjectMessage JavaDoc
16 {
17     private Object JavaDoc theObject;
18
19     /** Creates a new instance of LocalObjectMessage */
20     public LocalObjectMessage(IMessageDatagram md, IAcknowledgeHandler a)
21     {
22         super(md, a);
23         theObject = super.getBody();
24     }
25     public LocalObjectMessage(IMessageDatagramFactory f) {super(f);}
26
27     public int getMessageType() {return super.MSGTYPE_OBJECT;}
28
29     public void prepareForPublish()
30     {
31         super.prepareForPublish();
32         super.setBody(theObject);
33     }
34
35     public java.io.Serializable JavaDoc getObject()
36     {
37         return (java.io.Serializable JavaDoc)theObject;
38     }
39
40     public void setObject(java.io.Serializable JavaDoc serializable)
41         throws JMSException
42     {
43         if (!isWriteable())
44             throw new MessageNotWriteableException("not writeable");
45
46         this.theObject = serializable;
47     }
48
49     protected String JavaDoc bodyToHtml()
50     {
51         if (getObject() != null)
52             return "<b>Body Object</b><br>" + getObject().getClass() + "<br><pre>" + getObject().toString() + "</pre>";
53         else
54             return "<b>Body Object</b><br>null<br>";
55     }
56
57 }
58
Popular Tags