You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by cs...@apache.org on 2011/08/26 16:44:27 UTC

svn commit: r1162130 - /camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultExchangeTest.java

Author: cschneider
Date: Fri Aug 26 14:44:26 2011
New Revision: 1162130

URL: http://svn.apache.org/viewvc?rev=1162130&view=rev
Log:
CAMEL-4385 Test case that shows the problem

Modified:
    camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultExchangeTest.java

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultExchangeTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultExchangeTest.java?rev=1162130&r1=1162129&r2=1162130&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultExchangeTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultExchangeTest.java Fri Aug 26 14:44:26 2011
@@ -19,8 +19,10 @@ package org.apache.camel.impl;
 import java.io.IOException;
 import java.net.ConnectException;
 
+import org.apache.camel.Exchange;
 import org.apache.camel.ExchangeTestSupport;
 import org.apache.camel.InvalidPayloadException;
+import org.apache.camel.Message;
 import org.apache.camel.RuntimeCamelException;
 import org.apache.camel.util.ObjectHelper;
 
@@ -127,7 +129,16 @@ public class DefaultExchangeTest extends
         assertNotNull(my);
     }
 
-    private static class MyMessage extends DefaultMessage {
+    public void testCopy() {
+    	DefaultExchange sourceExchange =  new DefaultExchange(context);
+    	MyMessage sourceIn = new MyMessage();
+    	sourceExchange.setIn(sourceIn);
+    	Exchange destExchange = sourceExchange.copy();
+    	Message destIn = destExchange.getIn();
+    	assertEquals("dest message should be of the same type as source message", sourceIn.getClass(), destIn.getClass());
+    }
+    
+    public static class MyMessage extends DefaultMessage {
 
     }