You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cz...@apache.org on 2013/05/17 17:02:40 UTC
svn commit: r1483840 -
/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/ClassloadingTest.java
Author: cziegeler
Date: Fri May 17 15:02:40 2013
New Revision: 1483840
URL: http://svn.apache.org/r1483840
Log:
SLING-2868 : Improve and cleanup implementation : Remove unprocessed job from repository after test
Modified:
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/ClassloadingTest.java
Modified: sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/ClassloadingTest.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/ClassloadingTest.java?rev=1483840&r1=1483839&r2=1483840&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/ClassloadingTest.java (original)
+++ sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/it/ClassloadingTest.java Fri May 17 15:02:40 2013
@@ -168,7 +168,7 @@ public class ClassloadingTest extends Ab
final Map<String, Object> props = new HashMap<String, Object>();
props.put("dao", dao);
- jobManager.addJob(TOPIC + "/failed", null, props);
+ final String id = jobManager.addJob(TOPIC + "/failed", null, props).getId();
// we simply wait a little bit
sleep(2000);
@@ -179,6 +179,8 @@ public class ClassloadingTest extends Ab
assertEquals(0, jobManager.getStatistics().getNumberOfQueuedJobs());
assertEquals(0, jobManager.getStatistics().getNumberOfActiveJobs());
+ jobManager.removeJobById(id);
+ assertEquals(0, jobManager.findJobs(JobManager.QueryType.ALL, TOPIC + "/failed", -1, (Map<String, Object>[])null).size());
} finally {
jcReg.unregister();
ehReg.unregister();