fixed #48

Author: mgeipel

src/main/java/org/culturegraph/mf/stream/sink/SimpleXmlWriter.java

@@ -54,10 +54,20 @@ public final class SimpleXmlWriter extends DefaultStreamPipe<ObjectReceiver<Stri
 	private String recordTag = "record";
 	private String rootTag = "records";
 	private boolean start = true;
+	private boolean separateRoots;
+	private boolean writeXmlHeader=true;
 
 	public void setRootTag(final String rootTag) {
 		this.rootTag = rootTag;
 	}
+	
+	public void setWriteXmlHeader(final boolean writeXmlHeader) {
+		this.writeXmlHeader = writeXmlHeader;
+	}
+	
+	public void setSeparateRoots(final boolean separateRoots) {
+		this.separateRoots = separateRoots;
+	}
 
 	public void setNamespaceFile(final String file) {
 		final Properties properties = ResourceUtil.loadProperties(file);
@@ -68,7 +78,11 @@ public void setNamespaceFile(final String file) {
 
 	private void writeHeader() {
 		final StringBuilder builder = new StringBuilder();
-		builder.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n");
+		
+		if(writeXmlHeader){
+			builder.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n");
+		}
+		
 		builder.append("<");
 		builder.append(rootTag);
 		for (Entry<String, String> entry : namespaces.entrySet()) {
@@ -85,7 +99,7 @@ private void writeHeader() {
 
 	@Override
 	public void startRecord(final String identifier) {
-		if (start) {
+		if (separateRoots || start) {
 			writeHeader();
 		}
 		element = new Element(recordTag);
@@ -102,6 +116,9 @@ public void endRecord() {
 		} else {
 			getReceiver().process(element.toString());
 		}
+		if(separateRoots){
+			writeFooter();
+		}
 	}
 
 	@Override