svn commit: r832377 - in /camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms: JmsThrottlingInflightRoutePolicyTest.java JmsThrottlingRoutePolicyTest.java

[davsclaus]

Author: davsclaus
Date: Tue Nov  3 10:29:38 2009
New Revision: 832377

URL: http://svn.apache.org/viewvc?rev=832377&view=rev
Log:
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