Read a Bloomberg Message File

package com.northconcepts.datapipeline.examples.bloomberg;

import java.io.File;

import com.northconcepts.datapipeline.bloomberg.BloombergMessage;
import com.northconcepts.datapipeline.bloomberg.BloombergMessageReader;
import com.northconcepts.datapipeline.core.DataWriter;
import com.northconcepts.datapipeline.core.StreamWriter;
import com.northconcepts.datapipeline.job.Job;

public class ReadABloombergMessageFile {

    public static void main(String[] args) {
        File file = new File("data/input/example-talend-stackoverflow.req");
        
        BloombergMessageReader reader = new BloombergMessageReader(file);
        DataWriter writer = new StreamWriter(System.out);
        Job.run(reader,  writer);
        
        // message is available after BloombergMessageReader.open() is called in Job.run(reader,  writer) above
        BloombergMessage message = reader.getMessage();  
        System.out.println("-----------------------------------------------");
        System.out.println("Header: " + message.getHeader().getProperties());
        System.out.println("Fields: " + message.getFields().getFields());
        System.out.println("Records: " + message.getData().getRecords().size());
        System.out.println("Footers: " + message.getFooter().getProperties());
    }

}