DYFIIndexerWedge.java

package gov.usgs.earthquake.dyfi;

import gov.usgs.earthquake.distribution.ConfigurationException;
import gov.usgs.earthquake.distribution.ExternalNotificationListener;
import gov.usgs.earthquake.product.Product;
import gov.usgs.util.Config;

import java.util.logging.Logger;

/**
 * Legacy interface to trigger pre-Indexer ShakeMap processing.
 */
@Deprecated
public class DYFIIndexerWedge extends ExternalNotificationListener {

    private static final Logger LOGGER = Logger
            .getLogger("gov.usgs.earthquake.dyfi.DYFIIndexerWedge");

    /** Property for baseDirectory */
    public static final String BASE_DIRECTORY_PROPERTY = "baseDirectory";
    private String baseDirectory = null;

    /** Constructor */
    public DYFIIndexerWedge() {
        getIncludeTypes().add("dyfi");
    }

    /**
     * Builds the command to index the product. Just appends the relative
     * product directory (from the DYFILegacyStorage) to the configured index
     * command.
     *
     * @param product
     *            the Product used to build the indexing command.
     * @throws Exception if error occurs
     */
    @Override
    public String getProductCommand(final Product product) throws Exception {
        StringBuffer pc = new StringBuffer(getCommand());

        pc.append(" ").append("--directory=").append(baseDirectory)
                .append(getStorage().getProductPath(product.getId()));

        return pc.toString();
    }

    @Override
    public void configure(Config config) throws Exception {
        super.configure(config);

        // Base directory
        baseDirectory = config.getProperty(BASE_DIRECTORY_PROPERTY);
        if (baseDirectory == null) {
            throw new ConfigurationException("[" + getName()
                    + "] 'baseDirectory' is a required configuration property");
        }
        LOGGER.config("[" + getName() + "] baseDirectory is '" + baseDirectory
                + "'");
    }
}