*/
package mircoders.producer;
-import java.io.File;
-import java.util.Map;
-
import mir.entity.Entity;
import mir.entity.adapter.EntityAdapter;
import mir.log.LoggerWrapper;
import mir.producer.ProducerFailure;
import mir.producer.ProducerNode;
-import mir.util.FileFunctions;
+import mir.producer.ProductionContext;
+import mir.util.FileRoutines;
import mir.util.ParameterExpander;
import mircoders.entity.EntityContent;
import mircoders.search.IndexUtil;
+import java.io.File;
+
/**
* UnIndexingProducerNode is one of the 2 producer nodes that works on
* the search index db. There's IndexingProducerNode and
indexBasePath = anIndexBasePath;
}
- public void produce(Map aValueMap, String aVerb, LoggerWrapper aLogger) throws ProducerFailure {
+ public void produce(ProductionContext aProductionContext) throws ProducerFailure {
Object data;
Entity entity;
File indexFile;
startTime = System.currentTimeMillis();
try {
- indexFile = FileFunctions.getAbsoluteOrRelativeFile(indexBasePath, ParameterExpander.expandExpression(aValueMap, indexPath));
+ indexFile = FileRoutines.getAbsoluteOrRelativeFile(indexBasePath,
+ ParameterExpander.expandExpression(aProductionContext.getValueSet(), indexPath));
- data = ParameterExpander.findValueForKey( aValueMap, contentKey );
+ data = ParameterExpander.findValueForKey(aProductionContext.getValueSet(), contentKey);
if (! (data instanceof EntityAdapter)) {
throw new ProducerFailure("UnIndexingProducerNode: value of '"+contentKey+"' is not an EntityAdapter, but an " + data.getClass().getName(), null);
if (! (entity instanceof EntityContent)) {
throw new ProducerFailure("UnIndexingProducerNode: value of '"+contentKey+"' is not a content EntityAdapter, but a " + entity.getClass().getName() + " adapter", null);
}
- aLogger.info("UnIndexing " + entity.getFieldValue("id") + " out of " + indexFile.getAbsolutePath());
+ aProductionContext.getLogger().info("UnIndexing " + entity.getFieldValue("id") + " out of " + indexFile.getAbsolutePath());
IndexUtil.unindexEntity((EntityContent) entity, indexFile);
}
catch (Throwable t) {
- aLogger.error("Error while unindexing content: " + t.getMessage());
- t.printStackTrace(aLogger.asPrintWriter(LoggerWrapper.DEBUG_MESSAGE));
+ aProductionContext.getLogger().error("Error while unindexing content: " + t.getMessage());
+ t.printStackTrace(aProductionContext.getLogger().asPrintWriter(LoggerWrapper.DEBUG_MESSAGE));
}
endTime = System.currentTimeMillis();
- aLogger.info(" UnIndexTime: " + (endTime-startTime) + " ms<br>");
+ aProductionContext.getLogger().info(" UnIndexTime: " + (endTime-startTime) + " ms<br>");
}
}