Author: davsclaus
Date: Tue Nov 3 10:29:38 2009
New Revision: 832377
URL:
http://svn.apache.org/viewvc?rev=832377&view=revLog:
CAMEL-1048: Renamed throttler
Added:
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java (contents, props changed)
- copied, changed from r831887, camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingRoutePolicyTest.java
Removed:
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingRoutePolicyTest.java
Copied: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java (from r831887, camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingRoutePolicyTest.java)
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java?p2=camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java&p1=camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingRoutePolicyTest.java&r1=831887&r2=832377&rev=832377&view=diff==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingRoutePolicyTest.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java Tue Nov 3 10:29:38 2009
@@ -22,7 +22,7 @@
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.impl.ThrottlingRoutePolicy;
+import org.apache.camel.impl.ThrottlingInflightRoutePolicy;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;
import static org.apache.camel.component.jms.JmsComponent.jmsComponentTransacted;
@@ -30,7 +30,7 @@
/**
* @version $Revision$
*/
-public class JmsThrottlingRoutePolicyTest extends CamelTestSupport {
+public class JmsThrottlingInflightRoutePolicyTest extends CamelTestSupport {
private int size = 200;
@@ -41,7 +41,7 @@
}
@Test
- public void testJmsThrottlingRoutePolicy() throws Exception {
+ public void testJmsThrottlingInflightRoutePolicy() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMinimumMessageCount(size);
@@ -57,10 +57,10 @@
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- ThrottlingRoutePolicy policy = new ThrottlingRoutePolicy();
+ ThrottlingInflightRoutePolicy policy = new ThrottlingInflightRoutePolicy();
policy.setMaxInflightExchanges(10);
policy.setResumePercentOfMax(50);
- policy.setScope(ThrottlingRoutePolicy.ThrottlingScope.Route);
+ policy.setScope(ThrottlingInflightRoutePolicy.ThrottlingScope.Route);
from("activemq:queue:foo?concurrentConsumers=20").routePolicy(policy)
.delay(100)
Propchange: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java
------------------------------------------------------------------------------
svn:keywords = Rev Date