You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/09/02 13:33:57 UTC
svn commit: r810458 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedBrowseableEndpointTest.java
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