svn commit: r1648328 - /sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/JobHandlingTest.java

[cziegeler]

Author: cziegeler
Date: Mon Dec 29 13:04:27 2014
New Revision: 1648328

URL: http://svn.apache.org/r1648328
Log:
Reduce sleep times in test

Modified:
    
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/JobHandlingTest.java

Modified: 
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/JobHandlingTest.java
URL: 
http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/JobHandlingTest.java?rev=1648328&r1=1648327&r2=1648328&view=diff
==============================================================================
--- 
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/JobHandlingTest.java
 (original)
+++ 
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/JobHandlingTest.java
 Mon Dec 29 13:04:27 2014
@@ -151,11 +151,6 @@ public class JobHandlingTest extends Abs
 
                     @Override
                     public JobResult process(final Job job) {
-                        try {
-                            Thread.sleep(10);
-                        } catch (InterruptedException ie) {
-                            // ignore
-                        }
                         return JobResult.OK;
                     }
 
@@ -164,7 +159,7 @@ public class JobHandlingTest extends Abs
         final ServiceRegistration reg2 = 
this.registerEventHandler(NotificationConstants.TOPIC_JOB_FINISHED,
                 new EventHandler() {
                     @Override
-                    public void handleEvent(Event event) {
+                    public void handleEvent(final Event event) {
                         count.incrementAndGet();
                     }
                  });
@@ -176,11 +171,7 @@ public class JobHandlingTest extends Abs
                 this.getJobManager().addJob(TOPIC, null);
             }
             while ( count.get() < COUNT ) {
-                try {
-                    Thread.sleep(500);
-                } catch (InterruptedException ie) {
-                    // ignore
-                }
+                this.sleep(50);
             }
             assertEquals("Finished count", COUNT, count.get());
             assertEquals("Finished count", COUNT, 
this.getJobManager().getStatistics().getNumberOfFinishedJobs());
@@ -475,11 +466,7 @@ public class JobHandlingTest extends Abs
                 jobManager.addJob(jobTopic, null);
             }
             while ( jobManager.getStatistics().getNumberOfFinishedJobs() < 
COUNT / 2) {
-                try {
-                    Thread.sleep(100);
-                } catch (InterruptedException ie) {
-                    // ignore
-                }
+                this.sleep(50);
             }
 
             assertEquals("Finished count", COUNT / 2, count.get());