[MMBASE SCM] r42386 - mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams

[andre]

Author: andre
Date: 2010-06-02 15:20:00 +0200 (Wed, 02 Jun 2010)
New Revision: 42386

Modified:
   
mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/CreateCachesFunction.java
Log:
using unmodifiableMap to get config

Modified: 
mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/CreateCachesFunction.java
===================================================================
--- 
mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/CreateCachesFunction.java
  2010-06-02 13:19:30 UTC (rev 42385)
+++ 
mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/CreateCachesFunction.java
  2010-06-02 13:20:00 UTC (rev 42386)
@@ -96,8 +96,8 @@
             {
                 final Field url = node.getNodeManager().getField("url");
                 final Processor cc = getCacheCreator(url);                
-                Map<String, JobDefinition> jdlist = cc.getCreatecachesList();
-
+                Map<String, JobDefinition> jdlist = new LinkedHashMap<String, 
JobDefinition>();
+                
                 if (cache != null && 
node.getCloud().hasNode(cache.getNumber())) {
                     // just one
                     String in = null;
@@ -124,7 +124,6 @@
                     }
         
                     JobDefinition jd = new JobDefinition(id, in, label, tr, 
mt, Stage.TRANSCODER);
-                    jdlist.clear();
                     jdlist.put(id, jd);
                     LOG.info("Re-transcodig cache #" + cache.getNumber() + " : 
" + id + " [" + jd + "]");
                     
@@ -144,11 +143,15 @@
                     }
     
                     if ( list.size() > 0 && ! all ) {
-                        jdlist = newJobList(list, jdlist);
+                        jdlist = newJobList(list, cc.getConfiguration());
+                    } else {
+                        jdlist = cc.getConfiguration();
                     }
                     LOG.info("Re-transcoding caches for #" + node.getNumber() 
+ ", doing all: " + all);
                 }
                 
+                LOG.info("jdlist: " + jdlist);
+                
                 if (cc != null) {
                     LOG.service("Calling " + cc);
                     
cc.createCaches(node.getCloud().getNonTransactionalCloud(), node.getNumber(), 
jdlist);

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