DebugProductSender.java

  1. package gov.usgs.earthquake.eids;

  2. import gov.usgs.earthquake.distribution.ProductSender;
  3. import gov.usgs.earthquake.product.Product;
  4. import gov.usgs.earthquake.product.io.ObjectProductSource;
  5. import gov.usgs.earthquake.product.io.XmlProductHandler;
  6. import gov.usgs.util.DefaultConfigurable;
  7. import gov.usgs.util.StreamUtils;

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

  12.     /** Constructor */
  13.     public DebugProductSender() {
  14.         setName("debug_sender");
  15.     }

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

  21. }