catches stream exception

Author: schaeferd

src/main/java/org/culturegraph/mf/stream/pipe/StreamExceptionCatcher.java

@@ -0,0 +1,124 @@
+/**
+ * 
+ */
+package org.culturegraph.mf.stream.pipe;
+
+import org.culturegraph.mf.framework.DefaultStreamPipe;
+import org.culturegraph.mf.framework.StreamReceiver;
+import org.culturegraph.mf.framework.annotations.Description;
+import org.culturegraph.mf.framework.annotations.In;
+import org.culturegraph.mf.framework.annotations.Out;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * @author schaeferd
+ *
+ */
+@Description("passes streams events through and catches exceptions.")
+@In(StreamReceiver.class)
+@Out(StreamReceiver.class)
+public final class StreamExceptionCatcher extends
+		DefaultStreamPipe<StreamReceiver> {
+	
+	private static final Logger LOG = LoggerFactory.getLogger(StreamExceptionCatcher.class);
+	private static final String MSG_PATTERN = "{}{}";
+	
+	private final String logPrefix;
+	
+	public StreamExceptionCatcher() {
+		this("");
+	}
+	
+	public StreamExceptionCatcher(final String logPrefix) {
+		super();
+		this.logPrefix = logPrefix;
+	}
+	
+	
+	@Override
+	public void startRecord(final String identifier) {
+		try {
+			getReceiver().startRecord(identifier);
+			
+		} catch(final Exception e) {  
+			// NO CHECKSTYLE IllegalCatch FOR -1 LINES:
+			// This module is supposed to intercept _all_ exceptions
+			// thrown by downstream modules. Hence, we have to catch
+			// Exception.
+			LOG.error(MSG_PATTERN, logPrefix, "StartRecord" + identifier);
+			LOG.error(MSG_PATTERN, logPrefix, e);
+		}
+
+
+	}
+	
+	@Override
+	public void endRecord() {
+		try {
+			getReceiver().endRecord();
+			
+		} catch(final Exception e) {  
+			// NO CHECKSTYLE IllegalCatch FOR -1 LINES:
+			// This module is supposed to intercept _all_ exceptions
+			// thrown by downstream modules. Hence, we have to catch
+			// Exception.
+			LOG.error(MSG_PATTERN, logPrefix, "endRecord");
+			LOG.error(MSG_PATTERN, logPrefix, e);
+		}
+
+
+	}
+	
+	
+	@Override
+	public void startEntity(final String name) {
+		try {
+			getReceiver().startEntity(name);
+			
+		} catch(final Exception e) {  
+			// NO CHECKSTYLE IllegalCatch FOR -1 LINES:
+			// This module is supposed to intercept _all_ exceptions
+			// thrown by downstream modules. Hence, we have to catch
+			// Exception.
+			LOG.error(MSG_PATTERN, logPrefix, "startEntity" + name);
+			LOG.error(MSG_PATTERN, logPrefix, e);
+		}
+
+
+	}
+	@Override
+	public void endEntity() {
+		try {
+			getReceiver().endEntity();
+			
+		} catch(final Exception e) {  
+			// NO CHECKSTYLE IllegalCatch FOR -1 LINES:
+			// This module is supposed to intercept _all_ exceptions
+			// thrown by downstream modules. Hence, we have to catch
+			// Exception.
+			LOG.error(MSG_PATTERN, logPrefix, "endEntity");
+			LOG.error(MSG_PATTERN, logPrefix, e);
+		}
+
+
+	}
+	
+	@Override
+	public void literal(final String name, final String value) {
+		try {
+			getReceiver().literal(name, value);
+			
+		} catch(final Exception e) {  
+			// NO CHECKSTYLE IllegalCatch FOR -1 LINES:
+			// This module is supposed to intercept _all_ exceptions
+			// thrown by downstream modules. Hence, we have to catch
+			// Exception.
+			LOG.error(MSG_PATTERN, logPrefix, "literal " + name +" " + value);
+			LOG.error(MSG_PATTERN, logPrefix, e);
+		}
+
+
+	}
+
+}

src/main/resources/flux-commands.properties

@@ -94,6 +94,7 @@ filter-strings org.culturegraph.mf.stream.pipe.StringFilter
 draw-uniform-sample org.culturegraph.mf.stream.pipe.UniformSampler
 
 catch-object-exception org.culturegraph.mf.stream.pipe.ObjectExceptionCatcher
+catch-stream-exception org.culturegraph.mf.stream.pipe.StreamExceptionCatcher
 
 normalize-utf8 org.culturegraph.mf.stream.pipe.Utf8Normalizer