svn commit: r810458 - /camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedBrowseableEndpointTest.java

[davsclaus]

Author: davsclaus
Date: Wed Sep  2 11:33:57 2009
New Revision: 810458

URL: http://svn.apache.org/viewvc?rev=810458&view=rev
Log:
Fixed unit test

Modified:
    
camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedBrowseableEndpointTest.java

Modified: 
camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedBrowseableEndpointTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedBrowseableEndpointTest.java?rev=810458&r1=810457&r2=810458&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedBrowseableEndpointTest.java
 (original)
+++ 
camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedBrowseableEndpointTest.java
 Wed Sep  2 11:33:57 2009
@@ -21,7 +21,6 @@
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.ContextTestSupport;
-import org.apache.camel.Exchange;
 import org.apache.camel.builder.RouteBuilder;
 
 /**
@@ -55,13 +54,13 @@
         Long size = (Long) mbeanServer.invoke(name, "qeueSize", null, null);
         assertEquals(2, size.longValue());
 
-        Exchange exchange = (Exchange) mbeanServer.invoke(name, 
"browseExchange", new Object[]{0}, new String[]{"java.lang.Integer"});
-        assertNotNull(exchange);
-        assertEquals("Hello World", exchange.getIn().getBody());
-
-        exchange = (Exchange) mbeanServer.invoke(name, "browseExchange", new 
Object[]{1}, new String[]{"java.lang.Integer"});
-        assertNotNull(exchange);
-        assertEquals("Bye World", exchange.getIn().getBody());
+        String out = (String) mbeanServer.invoke(name, "browseExchange", new 
Object[]{0}, new String[]{"java.lang.Integer"});
+        assertNotNull(out);
+        assertTrue(out.contains("Hello World") );
+
+        out = (String) mbeanServer.invoke(name, "browseExchange", new 
Object[]{1}, new String[]{"java.lang.Integer"});
+        assertNotNull(out);
+        assertTrue(out.contains("Bye World") );
     }
 
     @Override