fixed #54

ObjectJavaIoWriter now optionally takes a IoWriterFactory as constructor
argument.

Author: mgeipel

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

@@ -0,0 +1,29 @@
+/*
+ *  Copyright 2013 Deutsche Nationalbibliothek
+ *
+ *  Licensed under the Apache License, Version 2.0 the "License";
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package org.culturegraph.mf.stream.sink;
+
+import java.io.Writer;
+
+/**
+ * Interface for classes creating {@link Writer}s. Used in {@link ObjectJavaIoWriter}.
+ * 
+ * @author markus geipel
+ *
+ */
+public interface IOWriterFactory {
+	Writer createWriter();
+}

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

@@ -31,11 +31,18 @@
 
 public final class ObjectJavaIoWriter<T> implements ObjectReceiver<T> {
 
-	private final Writer writer;
+	private Writer writer;
 	private boolean closed;
+	private final IOWriterFactory writerFactory;
 
 	public ObjectJavaIoWriter(final Writer writer) {
 		this.writer = writer;
+		writerFactory = null;
+	}
+	
+	public ObjectJavaIoWriter(final IOWriterFactory writerFactory) {
+		this.writerFactory = writerFactory;
+		this.writer = writerFactory.createWriter();
 	}
 
 	@Override
@@ -51,7 +58,11 @@ public void process(final T obj) {
 
 	@Override
 	public void resetStream() {
-		throw new UnsupportedOperationException("Cannot reset ObjectJavaIoWriter");
+		if(writerFactory==null){
+			throw new UnsupportedOperationException("Cannot reset ObjectJavaIoWriter. No IOWriterFactory set.");
+		}
+		writer = writerFactory.createWriter();
+		
 	}
 
 	@Override