KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > scalagent > kjoram > jms > AbstractJmsReply


1 /*
2  * JORAM: Java(TM) Open Reliable Asynchronous Messaging
3  * Copyright (C) 2001 - ScalAgent Distributed Technologies
4  * Copyright (C) 1996 - Dyade
5  *
6  * This library is free software; you can redistribute it and/or
7  * modify it under the terms of the GNU Lesser General Public
8  * License as published by the Free Software Foundation; either
9  * version 2.1 of the License, or any later version.
10  *
11  * This library is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14  * Lesser General Public License for more details.
15  *
16  * You should have received a copy of the GNU Lesser General Public
17  * License along with this library; if not, write to the Free Software
18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
19  * USA.
20  *
21  * Initial developer(s): Frederic Maistre (INRIA)
22  * Contributor(s): Nicolas Tachker (ScalAgent)
23  */
24 package com.scalagent.kjoram.jms;
25
26 import java.util.Hashtable JavaDoc;
27 import java.util.Enumeration JavaDoc;
28
29 /**
30  * An <code>AbstractJmsReply</code> is sent by a proxy to a Joram client as a
31  * reply to an <code>AbstractJmsRequest</code>.
32  */
33 public class AbstractJmsReply
34 {
35   /** Identifier of the replied request. */
36   protected int correlationId = -1;
37
38   /**
39    * Constructs an <code>AbstractJmsReply</code>.
40    *
41    * @param correlationId Identifier of the replied request.
42    */
43   public AbstractJmsReply(int correlationId)
44   {
45     this.correlationId = correlationId;
46   }
47
48   /**
49    * Constructs an <code>AbstractJmsReply</code>.
50    */
51   public AbstractJmsReply()
52   {}
53
54
55   /** Sets the replied request identifier. */
56   public void setCorrelationId(int correlationId)
57   {
58     this.correlationId = correlationId;
59   }
60
61   /** Returns the replied request identifier. */
62   public int getCorrelationId()
63   {
64     return correlationId;
65   }
66
67   /** Returns the identifier as an hashtable key. */
68   public Integer JavaDoc getKey()
69   {
70     return new Integer JavaDoc(correlationId);
71   }
72
73   public Hashtable JavaDoc soapCode() {
74     Hashtable JavaDoc h = new Hashtable JavaDoc();
75     String JavaDoc className = getClass().getName();
76     String JavaDoc end = className.substring(
77       className.lastIndexOf((int)'.'),
78       className.length());
79     h.put("className","org.objectweb.joram.shared.client"+end);
80     //h.put("className",getClass().getName());
81 h.put("correlationId",getKey());
82     return h;
83   }
84
85   public static Object JavaDoc soapDecode(Hashtable JavaDoc h) {
86     return new AbstractJmsReply(
87       ((Integer JavaDoc) h.get("correlationId")).intValue());
88   }
89 }
90
Popular Tags