[MMBASE SCM] r39868 - mmbase/trunk/applications/streams/src/test/java/org/mmbase/streams/createcaches

[michiel]

Author: michiel
Date: 2009-11-23 22:15:43 +0100 (Mon, 23 Nov 2009)
New Revision: 39868

Modified:
   
mmbase/trunk/applications/streams/src/test/java/org/mmbase/streams/createcaches/CreateCachesTest.java
Log:
just added some assertions

Modified: 
mmbase/trunk/applications/streams/src/test/java/org/mmbase/streams/createcaches/CreateCachesTest.java
===================================================================
--- 
mmbase/trunk/applications/streams/src/test/java/org/mmbase/streams/createcaches/CreateCachesTest.java
       2009-11-23 21:14:20 UTC (rev 39867)
+++ 
mmbase/trunk/applications/streams/src/test/java/org/mmbase/streams/createcaches/CreateCachesTest.java
       2009-11-23 21:15:43 UTC (rev 39868)
@@ -8,6 +8,7 @@
 import java.util.*;
 import java.io.*;
 import org.mmbase.bridge.*;
+import org.mmbase.bridge.util.Queries;
 import org.mmbase.datatypes.DataType;
 import static org.mmbase.datatypes.Constants.*;
 import org.mmbase.datatypes.processors.*;
@@ -100,6 +101,7 @@
             //remoteCloud.setProperty(BinaryCommitProcessor.NOT, "no implicit 
processesing please");
             
//remoteCloud.setProperty(org.mmbase.applications.media.FragmentTypeFixer.NOT, 
"no implicit processesing please");
         }
+        assumeNotNull(remoteCloud);
         return remoteCloud;
     }
 
@@ -162,7 +164,6 @@
     }
 
     Node refresh(Node source) throws InterruptedException {
-        //Thread.sleep(100);
         return source.getCloud().getNode(source.getNumber());
 
     }
@@ -213,14 +214,17 @@
 
     @Test
     public  void simple() throws Exception {
+        int fragmentsBefore = 
Queries.count(getCloud().getNodeManager("mediafragments").createQuery());
         Processor proc = get("dummycreatecaches_1.xml");
         Node source = getNode(proc.getDirectory());
+        assertEquals(fragmentsBefore + 1, 
Queries.count(getCloud().getNodeManager("mediafragments").createQuery()));
         Job job = proc.createCaches(source.getCloud(), source.getNumber());
         source.commit();
         job.waitUntil(Stage.READY);
         assertTrue(source.getCloud().hasNode(source.getNumber()));
         source = refresh(source);
         checkSource(source, 2);
+        assertEquals(fragmentsBefore + 1, 
Queries.count(getCloud().getNodeManager("mediafragments").createQuery()));
     }
 
 

_______________________________________________
Cvs mailing list
Cvs@lists.mmbase.org
http://lists.mmbase.org/mailman/listinfo/cvs