DebugProductSender.java

package gov.usgs.earthquake.distribution;

import gov.usgs.earthquake.product.Product;
import gov.usgs.earthquake.product.io.ObjectProductSource;
import gov.usgs.earthquake.product.io.XmlProductHandler;
import gov.usgs.util.DefaultConfigurable;
import gov.usgs.util.StreamUtils;

/**
 * Send products by printing them in xml format on the command line.
 */
public class DebugProductSender extends DefaultConfigurable implements ProductSender {

  /** Constructor */
  public DebugProductSender() {
    setName("debug_sender");
  }

  @Override
  public void sendProduct(Product product) throws Exception {
    new ObjectProductSource(product)
        .streamTo(new XmlProductHandler(new StreamUtils.UnclosableOutputStream(System.err)));
  }

}