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 2011/06/21 11:19:35 UTC
svn commit: r1137916 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/CustomLoadBalanceTest.java
Author: davsclaus
Date: Tue Jun 21 09:19:35 2011
New Revision: 1137916
URL: http://svn.apache.org/viewvc?rev=1137916&view=rev
Log:
Added wiki pages for documentation
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/CustomLoadBalanceTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/CustomLoadBalanceTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/CustomLoadBalanceTest.java?rev=1137916&r1=1137915&r2=1137916&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/CustomLoadBalanceTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/CustomLoadBalanceTest.java Tue Jun 21 09:19:35 2011
@@ -40,9 +40,12 @@ public class CustomLoadBalanceTest exten
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
+ // START SNIPPET: e1
from("direct:start")
+ // using our custom load balancer
.loadBalance(new MyLoadBalancer())
.to("mock:x", "mock:y", "mock:z");
+ // END SNIPPET: e1
}
};
}
@@ -64,6 +67,7 @@ public class CustomLoadBalanceTest exten
assertMockEndpointsSatisfied();
}
+ // START SNIPPET: e2
public static class MyLoadBalancer extends LoadBalancerSupport {
public boolean process(Exchange exchange, AsyncCallback callback) {
@@ -83,5 +87,6 @@ public class CustomLoadBalanceTest exten
return true;
}
}
+ // END SNIPPET: e2
}
\ No newline at end of file