[jboss-cvs] JBoss Messaging SVN: r8385 - in branches/Branch_1_4: tests/src/org/jboss/test/messaging/jms/message and 1 other directory.

[jboss-cvs-commits at lists.jboss.org]

Author: gaohoward
Date: 2011-07-15 06:13:23 -0400 (Fri, 15 Jul 2011)
New Revision: 8385

Modified:
   branches/Branch_1_4/src/main/org/jboss/jms/message/MessageProxy.java
   branches/Branch_1_4/tests/src/org/jboss/test/messaging/jms/message/TextMessageTest.java
Log:
JBMESSAGING-1888


Modified: branches/Branch_1_4/src/main/org/jboss/jms/message/MessageProxy.java
===================================================================
--- branches/Branch_1_4/src/main/org/jboss/jms/message/MessageProxy.java	2011-07-14 09:31:25 UTC (rev 8384)
+++ branches/Branch_1_4/src/main/org/jboss/jms/message/MessageProxy.java	2011-07-15 10:13:23 UTC (rev 8385)
@@ -96,7 +96,7 @@
    
    protected JBossMessage message;
    
-   private Object source;
+   private transient Object source;
 
    // Constructors --------------------------------------------------
 

Modified: branches/Branch_1_4/tests/src/org/jboss/test/messaging/jms/message/TextMessageTest.java
===================================================================
--- branches/Branch_1_4/tests/src/org/jboss/test/messaging/jms/message/TextMessageTest.java	2011-07-14 09:31:25 UTC (rev 8384)
+++ branches/Branch_1_4/tests/src/org/jboss/test/messaging/jms/message/TextMessageTest.java	2011-07-15 10:13:23 UTC (rev 8385)
@@ -22,10 +22,18 @@
 package org.jboss.test.messaging.jms.message;
 
 
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.ObjectInputStream;
+import java.io.ObjectOutputStream;
+
+import javax.jms.DeliveryMode;
 import javax.jms.JMSException;
 import javax.jms.Message;
 import javax.jms.TextMessage;
 
+import org.jboss.jms.message.MessageProxy;
+
 /**
  * A test that sends/receives text messages to the JMS provider and verifies their integrity.
  *
@@ -75,6 +83,26 @@
       assertEquals("something", rm.getText());
    }
    
+   //JBMESSAGING-1888
+   public void testMessageSerializable() throws Exception
+   {
+      queueProd.send(message);
+      
+      log.debug("Message sent");
+
+      Message r = queueCons.receive();
+      
+      log.debug("Message received");
+      
+      ByteArrayOutputStream byteOut = new ByteArrayOutputStream();
+      ObjectOutputStream cloneOut = new ObjectOutputStream(byteOut);
+      cloneOut.writeObject(r);
+      cloneOut.close();
+      ObjectInputStream inputArray = new ObjectInputStream (new ByteArrayInputStream(byteOut.toByteArray()));
+      Message clone = (Message)inputArray.readObject();      
+      log.info("cloned message: " + clone);
+   }
+   
    // Protected -----------------------------------------------------
 
    protected void prepareMessage(Message m) throws JMSException