introduced AdapterEntityModel
[mir.git] / source / mircoders / global / ProducerEngine.java
index 52e9a2f..19f9496 100755 (executable)
@@ -8,13 +8,13 @@ import multex.Exc;
 import multex.Failure;
 
 public class ProducerEngine {
-  private Map producers;
+//  private Map producers;
   private JobQueue producerJobQueue;
   private Thread queueThread;
   private PrintWriter log;
 
   protected ProducerEngine() {
-    producers = MirGlobal.localizer().producers().factories();
+//    producers = MirGlobal.localizer().producers().factories();
     producerJobQueue = new JobQueue();
     try {
       RandomAccessFile raFile = (new RandomAccessFile(MirGlobal.getConfigProperty("Home") + "/" + MirGlobal.getConfigProperty("Producer.Logfile"), "rw"));
@@ -66,12 +66,9 @@ public class ProducerEngine {
 
                  startTime = System.currentTimeMillis();
 
-      aLogger.println("Producing (" + aProducerFactory + "," + aVerb + ")<br>");
+      aLogger.println("Producing (" + aProducerFactory + "," + aVerb + ")");
 
-      if (producers == null)
-        aLogger.println("??<br>");
-
-      ProducerFactory factory = (ProducerFactory) producers.get(aProducerFactory);
+      ProducerFactory factory = (ProducerFactory) MirGlobal.localizer().producers().factories().get(aProducerFactory);
 
       if (factory == null )
         throw new Exception("No producer factory '"+aProducerFactory+"' present.");
@@ -114,7 +111,7 @@ public class ProducerEngine {
       log.println("Producing job: "+factoryName+"."+verb);
 
       try {
-        factory = (ProducerFactory) producers.get(factoryName);
+        factory = (ProducerFactory) MirGlobal.localizer().producers().factories().get( factoryName );
 
         if (factory!=null) {
           synchronized(factory) {