Author: cziegeler
Date: Tue Jan 25 12:56:35 2011
New Revision: 1063261
URL: http://svn.apache.org/viewvc?rev=1063261&view=rev
Log:
SLING-1955 : Event Support Unit Tests stall in full trunk build
Modified:
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java
Modified:
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java
URL:
http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java?rev=1063261&r1=1063260&r2=1063261&view=diff
==============================================================================
---
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java
(original)
+++
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java
Tue Jan 25 12:56:35 2011
@@ -145,6 +145,7 @@ public class OrderedJobQueueTest extends
public boolean process(Event job) {
if ( parallelCount.incrementAndGet() > 1 )
{
+ parallelCount.decrementAndGet();
return false;
}
final String topic =
(String)job.getProperty(JobUtil.PROPERTY_JOB_TOPIC);
Modified:
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java
URL:
http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java?rev=1063261&r1=1063260&r2=1063261&view=diff
==============================================================================
---
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java
(original)
+++
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java
Tue Jan 25 12:56:35 2011
@@ -147,6 +147,7 @@ public class RoundRobinQueueTest extends
public boolean process(Event job) {
if ( parallelCount.incrementAndGet() >
MAX_PAR ) {
+ parallelCount.decrementAndGet();
return false;
}
try {
