camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r670452 - in /activemq/camel/trunk/camel-core: pom.xml src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
Date Mon, 23 Jun 2008 06:36:00 GMT
Author: ningjiang
Date: Sun Jun 22 23:36:00 2008
New Revision: 670452

URL: http://svn.apache.org/viewvc?rev=670452&view=rev
Log:
Enable the DataSetSedaTest

Modified:
    activemq/camel/trunk/camel-core/pom.xml
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java

Modified: activemq/camel/trunk/camel-core/pom.xml
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/pom.xml?rev=670452&r1=670451&r2=670452&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/pom.xml (original)
+++ activemq/camel/trunk/camel-core/pom.xml Sun Jun 22 23:36:00 2008
@@ -123,7 +123,7 @@
           <forkMode>pertest</forkMode>
           <excludes>
             <!-- TODO FIXME ASAP -->
-            <exclude>**/DataSetSedaTest.*</exclude>
+            <exclude>**/XXXTest.*</exclude>
           </excludes>
         </configuration>
       </plugin>

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java?rev=670452&r1=670451&r2=670452&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
Sun Jun 22 23:36:00 2008
@@ -65,10 +65,10 @@
 
                 try {
                     long delay = endpoint.getProduceDelay();
-                    if (delay < 1) {
-                        // if no delay set then we must sleep at lest for 1 millis to avoid
concurrency
-                        // issues with extremly high throughtput
-                        delay = 1;
+                    if (delay < 3) {
+                        // if no delay set then we must sleep at lest for 3 millis to avoid
concurrency
+                        // issues with extremely high throughput
+                        delay = 3;
                     }
                     Thread.sleep(delay);
                 } catch (InterruptedException e) {



Mime
View raw message