Return-Path: 
 <camel-commits-return-2362-apmail-activemq-camel-commits-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-camel-commits-archive@locus.apache.org
Received: (qmail 54803 invoked from network); 23 Jun 2008 06:36:52 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 23 Jun 2008 06:36:52 -0000
Received: (qmail 19601 invoked by uid 500); 23 Jun 2008 06:36:54 -0000
Delivered-To: apmail-activemq-camel-commits-archive@activemq.apache.org
Received: (qmail 19562 invoked by uid 500); 23 Jun 2008 06:36:54 -0000
Mailing-List: contact camel-commits-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:camel-commits-help@activemq.apache.org>
List-Unsubscribe: <mailto:camel-commits-unsubscribe@activemq.apache.org>
List-Post: <mailto:camel-commits@activemq.apache.org>
List-Id: <camel-commits.activemq.apache.org>
Reply-To: camel-dev@activemq.apache.org
Delivered-To: mailing list camel-commits@activemq.apache.org
Received: (qmail 19553 invoked by uid 99); 23 Jun 2008 06:36:53 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 22 Jun 2008 23:36:53 -0700
X-ASF-Spam-Status: No, hits=-2000.0 required=10.0
	tests=ALL_TRUSTED
X-Spam-Check-By: apache.org
Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 23 Jun 2008 06:36:12 +0000
Received: by eris.apache.org (Postfix, from userid 65534)
	id 43A6D2388A02; Sun, 22 Jun 2008 23:36:01 -0700 (PDT)
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
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 -0000
To: camel-commits@activemq.apache.org
From: ningjiang@apache.org
X-Mailer: svnmailer-1.0.8
Message-Id: <20080623063601.43A6D2388A02@eris.apache.org>
X-Virus-Checked: Checked by ClamAV on apache.org

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) {