[Ejtools-cvs] CVS: applications/jndi.browser/src/main/net/sourceforge/ejtools/jndibrowser/model/jms MessageProxy.java,1.4,1.5

[Laurent E. <let...@us...>]

Update of /cvsroot/ejtools/applications/jndi.browser/src/main/net/sourceforge/ejtools/jndibrowser/model/jms
In directory usw-pr-cvs1:/tmp/cvs-serv7168/jndi.browser/src/main/net/sourceforge/ejtools/jndibrowser/model/jms

Modified Files:
	MessageProxy.java 
Log Message:
Add new proxy message for every types

Index: MessageProxy.java
===================================================================
RCS file: /cvsroot/ejtools/applications/jndi.browser/src/main/net/sourceforge/ejtools/jndibrowser/model/jms/MessageProxy.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** MessageProxy.java	12 May 2002 19:55:28 -0000	1.4
--- MessageProxy.java	12 May 2002 20:10:39 -0000	1.5
***************
*** 7,19 ****
  package net.sourceforge.ejtools.jndibrowser.model.jms;
  
! import java.awt.Component;
  import java.util.Date;
  import javax.jms.Destination;
  import javax.jms.JMSException;
  import javax.jms.Message;
  import javax.jms.TextMessage;
  
  import net.sourceforge.ejtools.jndibrowser.model.JNDIEntry;
- import org.apache.log4j.Category;
  
  /**
--- 7,24 ----
  package net.sourceforge.ejtools.jndibrowser.model.jms;
  
! import java.lang.reflect.Constructor;
  import java.util.Date;
+ import java.util.Hashtable;
+ 
+ import javax.jms.BytesMessage;
  import javax.jms.Destination;
  import javax.jms.JMSException;
+ import javax.jms.MapMessage;
  import javax.jms.Message;
+ import javax.jms.ObjectMessage;
+ import javax.jms.StreamMessage;
  import javax.jms.TextMessage;
  
  import net.sourceforge.ejtools.jndibrowser.model.JNDIEntry;
  
  /**
***************
*** 23,27 ****
--- 28,34 ----
   * @created   13 décembre 2001
   * @version   $Revision$
+  * @todo      Exceptions to detail
   * @todo      Javadoc to complete
+  * @todo      Add log4j logs
   */
  public class MessageProxy extends JNDIEntry
***************
*** 29,32 ****
--- 36,41 ----
     /** Description of the Field */
     protected Message message = null;
+    /** Description of the Field */
+    private static Hashtable proxies = new Hashtable();
  
  
***************
*** 173,182 ****
     public static MessageProxy createMessageProxy(String name, Message message)
     {
!       if (TextMessage.class.isAssignableFrom(message.getClass()))
        {
-          return new TextMessageProxy(name, message);
        }
        return new MessageProxy(name, message);
     }
- }
  
--- 182,208 ----
     public static MessageProxy createMessageProxy(String name, Message message)
     {
!       Class clazz = (Class) proxies.get(message.getClass());
! 
!       try
!       {
!          Constructor constructor = clazz.getConstructor(new Class[]{java.lang.String.class, javax.jms.Message.class});
!          MessageProxy proxy = (MessageProxy) constructor.newInstance(new Object[]{name, message});
!          return proxy;
!       }
!       catch (Exception e)
        {
        }
        return new MessageProxy(name, message);
     }
  
+    /** Load the list of proxies to create  */
+    static
+    {
+       proxies.put(javax.jms.Message.class, MessageProxy.class);
+       proxies.put(javax.jms.BytesMessage.class, BytesMessageProxy.class);
+       proxies.put(javax.jms.MapMessage.class, MapMessageProxy.class);
+       proxies.put(javax.jms.ObjectMessage.class, ObjectMessageProxy.class);
+       proxies.put(javax.jms.StreamMessage.class, StreamMessageProxy.class);
+       proxies.put(javax.jms.TextMessage.class, TextMessageProxy.class);
+    }
+ }