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