camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r810458 - /camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedBrowseableEndpointTest.java
Date Wed, 02 Sep 2009 11:33:57 GMT
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



Mime
View raw message