Hi Ashwin You seemed to add the file camel/trunk/.DS_Store by mistake.
Its a hidden file for Mac http://en.wikipedia.org/wiki/.DS_Store I would assume we should remove it from SVN. On Fri, Jan 28, 2011 at 10:43 PM, <aka...@apache.org> wrote: > Author: akarpe > Date: Fri Jan 28 21:43:25 2011 > New Revision: 1064901 > > URL: http://svn.apache.org/viewvc?rev=1064901&view=rev > Log: > CAMEL-3254 Added ability to set multiple policies on a route in Spring > and via API's > > Added: > camel/trunk/.DS_Store > > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java > > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringMultiplePoliciesOnRouteTest.java > > camel/trunk/components/camel-quartz/src/test/resources/org/apache/camel/routepolicy/quartz/MultiplePolicies.xml > Modified: > > camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java > > camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java > > camel/trunk/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java > camel/trunk/camel-core/src/main/java/org/apache/camel/spi/RouteContext.java > camel/trunk/components/camel-quartz/pom.xml > > camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledJob.java > > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java > > Added: camel/trunk/.DS_Store > URL: http://svn.apache.org/viewvc/camel/trunk/.DS_Store?rev=1064901&view=auto > ============================================================================== > Files camel/trunk/.DS_Store (added) and camel/trunk/.DS_Store Fri Jan 28 > 21:43:25 2011 differ > > Modified: > camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java > URL: > http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java?rev=1064901&r1=1064900&r2=1064901&view=diff > ============================================================================== > --- > camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java > (original) > +++ > camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java > Fri Jan 28 21:43:25 2011 > @@ -63,7 +63,7 @@ public class DefaultRouteContext impleme > private Boolean handleFault; > private Long delay; > private Boolean autoStartup = Boolean.TRUE; > - private RoutePolicy routePolicy; > + private List<RoutePolicy> routePolicyList = new ArrayList<RoutePolicy>(); > private ShutdownRoute shutdownRoute; > private ShutdownRunningTask shutdownRunningTask; > > @@ -154,15 +154,24 @@ public class DefaultRouteContext impleme > > // and then optionally add route policy processor if a custom > policy is set > RoutePolicyProcessor routePolicyProcessor = null; > - RoutePolicy policy = getRoutePolicy(); > - if (policy != null) { > - routePolicyProcessor = new > RoutePolicyProcessor(unitOfWorkProcessor, policy); > - // add it as service if we have not already done that (eg > possible if two routes have the same service) > - if (!camelContext.hasService(policy)) { > - try { > - camelContext.addService(policy); > - } catch (Exception e) { > - throw ObjectHelper.wrapRuntimeCamelException(e); > + List<RoutePolicy> policyList = getRoutePolicyList(); > + if (!policyList.isEmpty()) { > + boolean firstPolicy = true; > + for (RoutePolicy policy : policyList) { > + if (firstPolicy) { > + routePolicyProcessor = new > RoutePolicyProcessor(unitOfWorkProcessor, policy); > + firstPolicy = false; > + } else { > + routePolicyProcessor = new > RoutePolicyProcessor(routePolicyProcessor, policy); > + } > + > + // add it as service if we have not already done that > (eg possible if two routes have the same service) > + if (!camelContext.hasService(policy)) { > + try { > + camelContext.addService(policy); > + } catch (Exception e) { > + throw ObjectHelper.wrapRuntimeCamelException(e); > + } > } > } > target = routePolicyProcessor; > @@ -190,8 +199,10 @@ public class DefaultRouteContext impleme > } > > // invoke init on route policy > - if (policy != null) { > - policy.onInit(edcr); > + if (!policyList.isEmpty()) { > + for (RoutePolicy policy : policyList) { > + policy.onInit(edcr); > + } > } > > routes.add(edcr); > @@ -319,15 +330,7 @@ public class DefaultRouteContext impleme > return getCamelContext().getShutdownRunningTask(); > } > } > - > - public RoutePolicy getRoutePolicy() { > - return routePolicy; > - } > - > - public void setRoutePolicy(RoutePolicy routePolicy) { > - this.routePolicy = routePolicy; > - } > - > + > public int getAndIncrement(ProcessorDefinition<?> node) { > AtomicInteger count = nodeIndex.get(node); > if (count == null) { > @@ -336,4 +339,12 @@ public class DefaultRouteContext impleme > } > return count.getAndIncrement(); > } > + > + public void setRoutePolicyList(List<RoutePolicy> routePolicyList) { > + this.routePolicyList = routePolicyList; > + } > + > + public List<RoutePolicy> getRoutePolicyList() { > + return routePolicyList; > + } > } > > Modified: > camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java > URL: > http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java?rev=1064901&r1=1064900&r2=1064901&view=diff > ============================================================================== > --- > camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java > (original) > +++ > camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java > Fri Jan 28 21:43:25 2011 > @@ -16,6 +16,7 @@ > */ > package org.apache.camel.management.mbean; > > +import java.util.List; > import java.util.concurrent.TimeUnit; > > import org.apache.camel.CamelContext; > @@ -107,13 +108,17 @@ public class ManagedRoute extends Manage > route.getRouteContext().setTracing(tracing); > } > > - @ManagedAttribute(description = "Route Policy") > - public String getRoutePolicy() { > - RoutePolicy policy = route.getRouteContext().getRoutePolicy(); > - if (policy != null) { > + @ManagedAttribute(description = "Route Policy List") > + public String getRoutePolicyList() { > + List<RoutePolicy> policyList = > route.getRouteContext().getRoutePolicyList(); > + if (policyList != null) { > StringBuilder sb = new StringBuilder(); > - sb.append(policy.getClass().getSimpleName()); > - > sb.append("(").append(ObjectHelper.getIdentityHashCode(policy)).append(")"); > + for (RoutePolicy policy : policyList) { > + sb.append(policy.getClass().getSimpleName()); > + > sb.append("(").append(ObjectHelper.getIdentityHashCode(policy)).append(")"); > + sb.append(", "); > + } > + sb = sb.delete(sb.lastIndexOf(", "), sb.length() - 1); > return sb.toString(); > } > return null; > > Modified: > camel/trunk/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java > URL: > http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java?rev=1064901&r1=1064900&r2=1064901&view=diff > ============================================================================== > --- > camel/trunk/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java > (original) > +++ > camel/trunk/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java > Fri Jan 28 21:43:25 2011 > @@ -19,6 +19,7 @@ package org.apache.camel.model; > import java.util.ArrayList; > import java.util.Collection; > import java.util.List; > +import java.util.StringTokenizer; > import java.util.concurrent.atomic.AtomicBoolean; > import javax.xml.bind.annotation.XmlAccessType; > import javax.xml.bind.annotation.XmlAccessorType; > @@ -699,13 +700,16 @@ public class RouteDefinition extends Pro > if (log.isDebugEnabled()) { > log.debug("RoutePolicy is enabled: " + routePolicy + " on > route: " + this); > } > - routeContext.setRoutePolicy(getRoutePolicy()); > + routeContext.getRoutePolicyList().add(getRoutePolicy()); > } else if (routePolicyRef != null) { > - RoutePolicy policy = > CamelContextHelper.mandatoryLookup(camelContext, routePolicyRef, > RoutePolicy.class); > - if (log.isDebugEnabled()) { > - log.debug("RoutePolicy is enabled: " + policy + " on route: > " + this); > + StringTokenizer policyTokens = new > StringTokenizer(routePolicyRef, ","); > + while (policyTokens.hasMoreTokens()) { > + RoutePolicy policy = > CamelContextHelper.mandatoryLookup(camelContext, > policyTokens.nextToken().trim(), RoutePolicy.class); > + if (log.isDebugEnabled()) { > + log.debug("RoutePolicy is enabled: " + policy + " on > route: " + this); > + } > + routeContext.getRoutePolicyList().add(policy); > } > - routeContext.setRoutePolicy(policy); > } > > // configure auto startup > > Modified: > camel/trunk/camel-core/src/main/java/org/apache/camel/spi/RouteContext.java > URL: > http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/RouteContext.java?rev=1064901&r1=1064900&r2=1064901&view=diff > ============================================================================== > --- > camel/trunk/camel-core/src/main/java/org/apache/camel/spi/RouteContext.java > (original) > +++ > camel/trunk/camel-core/src/main/java/org/apache/camel/spi/RouteContext.java > Fri Jan 28 21:43:25 2011 > @@ -173,18 +173,18 @@ public interface RouteContext extends Ru > boolean isRouteAdded(); > > /** > - * Gets the route policy > + * Gets the route policy List > * > - * @return the route policy if any > + * @return the route policy list if any > */ > - RoutePolicy getRoutePolicy(); > + List<RoutePolicy> getRoutePolicyList(); > > /** > - * Sets a custom route policy > + * Sets a custom route policy List > * > - * @param routePolicy the custom route policy > + * @param routePolicyList the custom route policy list > */ > - void setRoutePolicy(RoutePolicy routePolicy); > + void setRoutePolicyList(List<RoutePolicy> routePolicyList); > > /** > * A private counter that increments, is used to as book keeping > > Modified: camel/trunk/components/camel-quartz/pom.xml > URL: > http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/pom.xml?rev=1064901&r1=1064900&r2=1064901&view=diff > ============================================================================== > --- camel/trunk/components/camel-quartz/pom.xml (original) > +++ camel/trunk/components/camel-quartz/pom.xml Fri Jan 28 21:43:25 2011 > @@ -73,6 +73,11 @@ > </dependency> > <dependency> > <groupId>org.apache.camel</groupId> > + <artifactId>camel-core-xml</artifactId> > + <scope>test</scope> > + </dependency> > + <dependency> > + <groupId>org.apache.camel</groupId> > <artifactId>camel-test</artifactId> > <scope>test</scope> > </dependency> > > Modified: > camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledJob.java > URL: > http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledJob.java?rev=1064901&r1=1064900&r2=1064901&view=diff > ============================================================================== > --- > camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledJob.java > (original) > +++ > camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledJob.java > Fri Jan 28 21:43:25 2011 > @@ -17,8 +17,10 @@ > package org.apache.camel.routepolicy.quartz; > > import java.io.Serializable; > +import java.util.List; > > import org.apache.camel.Route; > +import org.apache.camel.spi.RoutePolicy; > import org.quartz.Job; > import org.quartz.JobExecutionContext; > import org.quartz.JobExecutionException; > @@ -45,11 +47,15 @@ public class ScheduledJob implements Job > Action storedAction = state.getAction(); > storedRoute = state.getRoute(); > > - ScheduledRoutePolicy policy = (ScheduledRoutePolicy) > storedRoute.getRouteContext().getRoutePolicy(); > - try { > - policy.onJobExecute(storedAction, storedRoute); > - } catch (Exception e) { > - throw new JobExecutionException("Failed to execute Scheduled Job > for route " + storedRoute.getId() + " with trigger name: " + > jobExecutionContext.getTrigger().getFullName()); > + List<RoutePolicy> policyList = > storedRoute.getRouteContext().getRoutePolicyList(); > + for (RoutePolicy policy : policyList) { > + try { > + if (policy instanceof ScheduledRoutePolicy) { > + > ((ScheduledRoutePolicy)policy).onJobExecute(storedAction, storedRoute); > + } > + } catch (Exception e) { > + throw new JobExecutionException("Failed to execute Scheduled > Job for route " + storedRoute.getId() + " with trigger name: " + > jobExecutionContext.getTrigger().getFullName()); > + } > } > } > > > Added: > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java > URL: > http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java?rev=1064901&view=auto > ============================================================================== > --- > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java > (added) > +++ > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java > Fri Jan 28 21:43:25 2011 > @@ -0,0 +1,112 @@ > +/** > + * 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.routepolicy.quartz; > + > +import java.util.Date; > +import java.util.concurrent.TimeUnit; > + > +import org.apache.camel.CamelExecutionException; > +import org.apache.camel.ServiceStatus; > +import org.apache.camel.builder.RouteBuilder; > +import org.apache.camel.component.mock.MockEndpoint; > +import org.apache.camel.component.quartz.QuartzComponent; > +import org.apache.camel.impl.JndiRegistry; > +import org.apache.camel.impl.ThrottlingInflightRoutePolicy; > +import org.apache.camel.spi.RoutePolicy; > +import org.apache.camel.test.junit4.CamelTestSupport; > +import org.apache.camel.util.ServiceHelper; > +import org.apache.commons.logging.Log; > +import org.apache.commons.logging.LogFactory; > +import org.junit.Test; > + > +/** > + * @version $Revision: 882486 $ > + */ > +public class MultiplePoliciesOnRouteTest extends CamelTestSupport { > + private static final transient Log LOG = > LogFactory.getLog(MultiplePoliciesOnRouteTest.class); > + private String url = "seda:foo?concurrentConsumers=20"; > + private int size = 100; > + > + /* (non-Javadoc) > + * @see org.apache.camel.test.junit4.CamelTestSupport#s;etUp() > + */ > + @Override > + public void setUp() throws Exception { > + super.setUp(); > + } > + > + @Override > + protected JndiRegistry createRegistry() throws Exception { > + JndiRegistry registry = new JndiRegistry(createJndiContext()); > + registry.bind("startPolicy", createRouteStartPolicy()); > + registry.bind("throttlePolicy", createThrottlePolicy()); > + return registry; > + } > + > + /* (non-Javadoc) > + * @see org.apache.camel.test.junit4.CamelTestSupport#isUseRouteBuilder() > + */ > + @Override > + public boolean isUseRouteBuilder() { > + return false; > + } > + > + private RoutePolicy createRouteStartPolicy() { > + SimpleScheduledRoutePolicy policy = new SimpleScheduledRoutePolicy(); > + long startTime = System.currentTimeMillis() + 3000L; > + policy.setRouteStartDate(new Date(startTime)); > + policy.setRouteStartRepeatCount(1); > + policy.setRouteStartRepeatInterval(3000); > + > + return policy; > + } > + > + private RoutePolicy createThrottlePolicy() { > + ThrottlingInflightRoutePolicy policy = new > ThrottlingInflightRoutePolicy(); > + policy.setMaxInflightExchanges(10); > + return policy; > + } > + > + @Test > + public void testMultiplePoliciesOnRoute() throws Exception { > + MockEndpoint success = (MockEndpoint) > context.getEndpoint("mock:success"); > + > + success.expectedMinimumMessageCount(size - 10); > + > + context.getComponent("quartz", > QuartzComponent.class).setPropertiesFile("org/apache/camel/routepolicy/quartz/myquartz.properties"); > + context.getComponent("quartz", QuartzComponent.class).start(); > + context.addRoutes(new RouteBuilder() { > + public void configure() { > + from(url) > + .routeId("test") > + .routePolicyRef("startPolicy, throttlePolicy") > + .to("log:foo?groupSize=10") > + .to("mock:success"); > + } > + }); > + context.start(); > + assertTrue(context.getRouteStatus("test") == ServiceStatus.Started); > + for (int i = 0; i < size; i++) { > + template.sendBody(url, "Message " + i); > + Thread.sleep(3); > + } > + > + context.getComponent("quartz", QuartzComponent.class).stop(); > + success.assertIsSatisfied(); > + } > + > +} > > Added: > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringMultiplePoliciesOnRouteTest.java > URL: > http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringMultiplePoliciesOnRouteTest.java?rev=1064901&view=auto > ============================================================================== > --- > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringMultiplePoliciesOnRouteTest.java > (added) > +++ > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringMultiplePoliciesOnRouteTest.java > Fri Jan 28 21:43:25 2011 > @@ -0,0 +1,56 @@ > +/** > + * 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.routepolicy.quartz; > + > +import org.apache.camel.test.CamelSpringTestSupport; > +import org.apache.camel.test.CamelTestSupport; > +import org.junit.Before; > +import org.junit.Test; > +import org.springframework.context.support.AbstractApplicationContext; > +import org.springframework.context.support.ClassPathXmlApplicationContext; > + > +/** > + * @version $Revision$ > + */ > +public class SpringMultiplePoliciesOnRouteTest extends > CamelSpringTestSupport { > + private String url = "seda:foo?concurrentConsumers=20"; > + private int size = 100; > + > + @Test > + public void testMultiplePoliciesOnRoute() throws Exception { > + // we use seda which are not persistent and hence can loose a message > + // when we get graceful shutdown support we can prevent this > + getMockEndpoint("mock:success").expectedMinimumMessageCount(size - > 10); > + > + for (int i = 0; i < size; i++) { > + template.sendBody(url, "Message " + i); > + Thread.sleep(3); > + } > + > + assertMockEndpointsSatisfied(); > + } > + > + /* (non-Javadoc) > + * @see > org.apache.camel.test.CamelSpringTestSupport#createApplicationContext() > + */ > + @Override > + protected AbstractApplicationContext createApplicationContext() { > + // TODO Auto-generated method stub > + return new > ClassPathXmlApplicationContext("org/apache/camel/routepolicy/quartz/MultiplePolicies.xml"); > + } > + > +} > > Modified: > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java > URL: > http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java?rev=1064901&r1=1064900&r2=1064901&view=diff > ============================================================================== > --- > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java > (original) > +++ > camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java > Fri Jan 28 21:43:25 2011 > @@ -117,7 +117,7 @@ public abstract class SpringScheduledRou > context.start(); > return context; > } > - > + > public ClassPathXmlApplicationContext getApplicationContext() { > return applicationContext; > } > > Added: > camel/trunk/components/camel-quartz/src/test/resources/org/apache/camel/routepolicy/quartz/MultiplePolicies.xml > URL: > http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/test/resources/org/apache/camel/routepolicy/quartz/MultiplePolicies.xml?rev=1064901&view=auto > ============================================================================== > --- > camel/trunk/components/camel-quartz/src/test/resources/org/apache/camel/routepolicy/quartz/MultiplePolicies.xml > (added) > +++ > camel/trunk/components/camel-quartz/src/test/resources/org/apache/camel/routepolicy/quartz/MultiplePolicies.xml > Fri Jan 28 21:43:25 2011 > @@ -0,0 +1,44 @@ > +<?xml version="1.0" encoding="UTF-8"?> > +<!-- > + 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. > +--> > +<beans xmlns="http://www.springframework.org/schema/beans"; > + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > + xsi:schemaLocation=" > + http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans.xsd > + http://camel.apache.org/schema/spring > http://camel.apache.org/schema/spring/camel-spring.xsd > + "> > + > + <bean id="date" class="org.apache.camel.routepolicy.quartz.SimpleDate"/> > + > + <bean id="startPolicy" > class="org.apache.camel.routepolicy.quartz.SimpleScheduledRoutePolicy"> > + <property name="routeStartDate" ref="date"/> > + <property name="routeStartRepeatCount" value="1"/> > + <property name="routeStartRepeatInterval" value="3000"/> > + </bean> > + > + <bean id="throttlePolicy" > class="org.apache.camel.impl.ThrottlingInflightRoutePolicy"> > + <property name="maxInflightExchanges" value="10"/> > + </bean> > + > + <camelContext id="testRouteContext" > xmlns="http://camel.apache.org/schema/spring";> > + <route id="testRoute" autoStartup="false" > routePolicyRef="startPolicy, throttlePolicy"> > + <from uri="seda:foo?concurrentConsumers=20"/> > + <to uri="mock:success"/> > + </route> > + </camelContext> > + > +</beans> > > > -- Claus Ibsen ----------------- FuseSource Email: cib...@fusesource.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.blogspot.com/ Author of Camel in Action: http://www.manning.com/ibsen/
