package org.finra.datagenerator.consumer.defaults;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.atomic.AtomicBoolean;

/**
 * Created by RobbinBr on 5/18/2014.
 */
public class ConsumerResult {

    private final Map<String, String> dataMap = new HashMap<String, String>();
    private final AtomicBoolean exitFlag;
    private final long maxNumberOfLines;

    public ConsumerResult(long maxNumberOfLines, AtomicBoolean exitFlag) {
        this.maxNumberOfLines = maxNumberOfLines;
        this.exitFlag = exitFlag;
    }

    public Map<String, String> getDataMap() {
        return dataMap;
    }

    public AtomicBoolean getExitFlag() {
        return exitFlag;
    }

    public long getMaxNumberOfLines() {
        return maxNumberOfLines;
    }
}
@@ -777,10 +777,339 @@
 s;%0A    %7D
+%0A%0A    public String getPipeDelimited()%7B%0A        StringBuilder b = new StringBuilder(1024);%0A        for (Map.Entry%3CString, String%3E entry : getDataMap().entrySet()) %7B%0A            if (b.length() %3E 0) %7B%0A                b.append('%7C');%0A            %7D%0A            b.append(entry.getValue());%0A        %7D%0A%0A        return b.toString();%0A    %7D
 %0A%7D

Update ConsumerResult to handle pipe-deliminting formatting