Repository: camel
Updated Branches:
refs/heads/master 8dbdfd28b - a93800e6e
CAMEL-8957: Added unit test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a93800e6
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a93800e6
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a93800e6
Branch: refs/heads/master
Commit: a93800e6ee1a3a27833a408f0ae0eb7b1440ad8b
Parents: 8dbdfd2
Author: Christian Mueller cmuel...@apache.org
Authored: Mon Jul 20 19:11:05 2015 +0200
Committer: Christian Mueller cmuel...@apache.org
Committed: Mon Jul 20 19:11:05 2015 +0200
--
...rceptSendToEndpointWithLoadbalancerTest.java | 70
...erceptSendToEndpointWithLoadbalancerTest.xml | 30 +
2 files changed, 100 insertions(+)
--
http://git-wip-us.apache.org/repos/asf/camel/blob/a93800e6/components/camel-test-spring/src/test/java/org/apache/camel/test/issues/AdviceWithInterceptSendToEndpointWithLoadbalancerTest.java
--
diff --git
a/components/camel-test-spring/src/test/java/org/apache/camel/test/issues/AdviceWithInterceptSendToEndpointWithLoadbalancerTest.java
b/components/camel-test-spring/src/test/java/org/apache/camel/test/issues/AdviceWithInterceptSendToEndpointWithLoadbalancerTest.java
new file mode 100644
index 000..9bb41c8
--- /dev/null
+++
b/components/camel-test-spring/src/test/java/org/apache/camel/test/issues/AdviceWithInterceptSendToEndpointWithLoadbalancerTest.java
@@ -0,0 +1,70 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the License); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.test.issues;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.camel.builder.AdviceWithRouteBuilder;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.RouteDefinition;
+import org.apache.camel.test.spring.CamelSpringTestSupport;
+import org.junit.Test;
+import org.springframework.context.support.AbstractApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class AdviceWithInterceptSendToEndpointWithLoadbalancerTest extends
CamelSpringTestSupport {
+
+@Override
+protected AbstractApplicationContext createApplicationContext() {
+return new
ClassPathXmlApplicationContext(org/apache/camel/test/issues/AdviceWithInterceptSendToEndpointWithLoadbalancerTest.xml);
+}
+
+@Override
+public boolean isUseAdviceWith() {
+return true;
+}
+
+@Test
+public void testSimpleMultipleAdvice() throws Exception {
+RouteDefinition route = context.getRouteDefinitions().get(0);
+route.adviceWith(context, new RouteBuilder() {
+public void configure() throws Exception {
+interceptSendToEndpoint(seda:end1)
+.skipSendToOriginalEndpoint()
+.to(mock:end);
+}
+});
+
+context.start();
+
+getMockEndpoint(mock:end).expectedMessageCount(1);
+
+template.sendBody(direct:start, Hello World);
+
+assertMockEndpointsSatisfied();
+}
+
+public static class LoadbalancerTestRoute extends RouteBuilder {
+
+@Override
+public void configure() throws Exception {
+from(direct:start)
+.loadBalance().failover()
+.to(seda:end1, seda:end2);
+}
+}
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/a93800e6/components/camel-test-spring/src/test/resources/org/apache/camel/test/issues/AdviceWithInterceptSendToEndpointWithLoadbalancerTest.xml
--
diff --git
a/components/camel-test-spring/src/test/resources/org/apache/camel/test/issues/AdviceWithInterceptSendToEndpointWithLoadbalancerTest.xml
b/components/camel-test-spring/src/test/resources/org/apache/camel/test/issues/AdviceWithInterceptSendToEndpointWithLoadbalancerTest.xml
new file mode 100644
index 000..7fb613d
---
