fixed #36

ObjectExceptionLogger depricated

Author: mgeipel

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

@@ -13,63 +13,64 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
-
-import org.culturegraph.mf.framework.DefaultObjectPipe;
-import org.culturegraph.mf.framework.ObjectReceiver;
-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;
-
-
-/**
- * Logs the string representation of every object.
- * 
- * @param <T> object type
- * 
- * @author Christoph Böhme
- * 
- */
-@Description("logs objects with the toString method")
-@In(Object.class)
-@Out(Object.class)
-public final class ObjectExceptionLogger<T> 
-		extends DefaultObjectPipe<T, ObjectReceiver<T>> {
-	
-	private static final Logger LOG = LoggerFactory.getLogger(ObjectExceptionLogger.class);
-
-	private final String logPrefix;
-
-	public ObjectExceptionLogger() {
-		this("");
-	}
-	
-	public ObjectExceptionLogger(final String logPrefix) {
-		super();
-		this.logPrefix = logPrefix;
-	}
-
-	@Override
-	public void process(final T obj) {
-		
-		try{
-			getReceiver().process(obj);
-		}catch(Exception e){
-			LOG.error(logPrefix, e);
-		}
-		
-	}
-
-	@Override
-	protected void onResetStream() {
-		LOG.debug("{}resetStream", logPrefix);
-	}
-	
-	@Override
-	protected void onCloseStream() {
-		LOG.debug("{}closeStream", logPrefix);
-	}
-
-}
+package org.culturegraph.mf.stream.pipe;
+
+import org.culturegraph.mf.framework.DefaultObjectPipe;
+import org.culturegraph.mf.framework.ObjectReceiver;
+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;
+
+
+/**
+ * Logs the string representation of every object.
+ * 
+ * @param <T> object type
+ * @deprecated use {@link ObjectExceptionLogger} instead.
+ * @author Christoph Böhme
+ * 
+ */
+@Description("logs objects with the toString method")
+@In(Object.class)
+@Out(Object.class)
+@Deprecated
+public final class ObjectExceptionLogger<T> 
+		extends DefaultObjectPipe<T, ObjectReceiver<T>> {
+	
+	private static final Logger LOG = LoggerFactory.getLogger(ObjectExceptionLogger.class);
+
+	private final String logPrefix;
+
+	public ObjectExceptionLogger() {
+		this("");
+	}
+	
+	public ObjectExceptionLogger(final String logPrefix) {
+		super();
+		this.logPrefix = logPrefix;
+	}
+
+	@Override
+	public void process(final T obj) {
+		
+		try{
+			getReceiver().process(obj);
+		}catch(Exception e){
+			LOG.error(logPrefix, e);
+		}
+		
+	}
+
+	@Override
+	protected void onResetStream() {
+		LOG.debug("{}resetStream", logPrefix);
+	}
+	
+	@Override
+	protected void onCloseStream() {
+		LOG.debug("{}closeStream", logPrefix);
+	}
+
+}

src/main/resources/flux-commands.properties

@@ -45,7 +45,7 @@ write	org.culturegraph.mf.stream.sink.ObjectWriter
 log-stream	org.culturegraph.mf.stream.pipe.StreamLogger
 log-object	org.culturegraph.mf.stream.pipe.ObjectLogger
 log-time	org.culturegraph.mf.stream.pipe.ObjectTimer
-catch-exceptions org.culturegraph.mf.stream.pipe.ObjectExceptionCatcher
+#catch-exceptions org.culturegraph.mf.stream.pipe.ObjectExceptionCatcher (dublicate entry)
 decouple org.culturegraph.mf.stream.pipe.ObjectPipeDecoupler
 
 change-id	org.culturegraph.mf.stream.pipe.IdChangePipe