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"));
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.");
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) {