Class CsvValidatingAggregator

  • All Implemented Interfaces:
    MessageAggregator

    @ComponentProfile(summary="Aggregate messages into a CSV, optionally prefixing a header",
                      since="3.10.0",
                      tag="csv,aggregator,validate")
    public class CsvValidatingAggregator
    extends CsvAggregating
    Attempts to aggregate messages into a CSV file. This aggregator attempts to validate the CSV by making use of the Apache Commons CSV library. If a header is set then it defines how many columns each row should have, otherwise the first record in the first message dictates this. Each record is parsed using the Commons CSV Parser, which will (hopefully) ensure that the record is valid CSV.
    • Constructor Detail

      • CsvValidatingAggregator

        public CsvValidatingAggregator()
    • Method Detail

      • getForceColumns

        public java.lang.Boolean getForceColumns()
      • setForceColumns

        public void setForceColumns​(java.lang.Boolean forceColumns)