producers = MirGlobal.localizer().producers().factories();
producerJobQueue = new JobQueue();
try {
- log = new PrintWriter(new FileWriter(new File("/tmp/producer.log")));
+ RandomAccessFile raFile = (new RandomAccessFile(MirGlobal.getConfigProperty("Home") + "/" + MirGlobal.getConfigProperty("Producer.Logfile"), "rw"));
+ raFile.seek(raFile.length());
+ log = new PrintWriter(new FileWriter( raFile.getFD()));
}
catch (Exception e) {
- throw new ProducerEngineRuntimeExc("Creating PrintWriter log failed",e);
+// throw new ProducerEngineRuntimeExc("Creating PrintWriter log failed",e);
+ log = new PrintWriter(new NullWriter());
}
queueThread = new Thread(new ProducerJobQueueThread());
queueThread.start();
}
public void addJob(String aProducerFactory, String aVerb) {
+// ML: TODO: should check if a similar job is already pending
producerJobQueue.appendJob(new ProducerJob(aProducerFactory, aVerb));
log.println(aProducerFactory+"."+aVerb+" added to queue");
log.flush();