Create monitoring package

cboehme · cboehme · commit fb9c254ab63a · 2016-12-25T08:36:14.000+01:00
The `monitoring` package contains modules for monitoring and debugging a
Metafacture pipeline.
diff --git a/src/main/java/org/culturegraph/mf/monitoring/ObjectBatchLogger.java b/src/main/java/org/culturegraph/mf/monitoring/ObjectBatchLogger.java
@@ -1,6 +1,5 @@
 /*
  * Copyright 2016 Christoph Böhme
- * Copyright 2013, 2014 Deutsche Nationalbibliothek
  *
  * Licensed under the Apache License, Version 2.0 the "License";
  * you may not use this file except in compliance with the License.
@@ -14,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import java.util.HashMap;
 import java.util.Map;
diff --git a/src/main/java/org/culturegraph/mf/monitoring/ObjectLogger.java b/src/main/java/org/culturegraph/mf/monitoring/ObjectLogger.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import org.culturegraph.mf.framework.FluxCommand;
 import org.culturegraph.mf.framework.ObjectReceiver;
diff --git a/src/main/java/org/culturegraph/mf/monitoring/ObjectTimer.java b/src/main/java/org/culturegraph/mf/monitoring/ObjectTimer.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import org.culturegraph.mf.framework.FluxCommand;
 import org.culturegraph.mf.framework.ObjectPipe;
diff --git a/src/main/java/org/culturegraph/mf/monitoring/StreamBatchLogger.java b/src/main/java/org/culturegraph/mf/monitoring/StreamBatchLogger.java
@@ -1,6 +1,5 @@
 /*
  * Copyright 2016 Christoph Böhme
- * Copyright 2013, 2014 Deutsche Nationalbibliothek
  *
  * Licensed under the Apache License, Version 2.0 the "License";
  * you may not use this file except in compliance with the License.
@@ -14,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import java.util.HashMap;
 import java.util.Map;
diff --git a/src/main/java/org/culturegraph/mf/monitoring/StreamLogger.java b/src/main/java/org/culturegraph/mf/monitoring/StreamLogger.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import org.culturegraph.mf.framework.FluxCommand;
 import org.culturegraph.mf.framework.StreamReceiver;
diff --git a/src/main/java/org/culturegraph/mf/monitoring/StreamTimer.java b/src/main/java/org/culturegraph/mf/monitoring/StreamTimer.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import org.culturegraph.mf.framework.FluxCommand;
 import org.culturegraph.mf.framework.StreamPipe;
diff --git a/src/main/java/org/culturegraph/mf/monitoring/TimerBase.java b/src/main/java/org/culturegraph/mf/monitoring/TimerBase.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import org.culturegraph.mf.commons.TimeUtil;
 import org.culturegraph.mf.framework.Receiver;
diff --git a/src/main/resources/flux-commands.properties b/src/main/resources/flux-commands.properties
@@ -76,10 +76,10 @@ write-xml-files org.culturegraph.mf.xml.XmlFilenameWriter
 write-files org.culturegraph.mf.io.ObjectFileWriter
 print org.culturegraph.mf.io.ObjectStdoutWriter
 
-log-stream	org.culturegraph.mf.stream.pipe.StreamLogger
-log-object	org.culturegraph.mf.stream.pipe.ObjectLogger
-log-time	org.culturegraph.mf.stream.pipe.ObjectTimer
-log-stream-time org.culturegraph.mf.stream.pipe.StreamTimer
+log-stream	org.culturegraph.mf.monitoring.StreamLogger
+log-object	org.culturegraph.mf.monitoring.ObjectLogger
+log-time	org.culturegraph.mf.monitoring.ObjectTimer
+log-stream-time org.culturegraph.mf.monitoring.StreamTimer
 
 change-id	org.culturegraph.mf.mangling.RecordIdChanger
 flatten	org.culturegraph.mf.mangling.StreamFlattener
@@ -99,8 +99,8 @@ xml-tee	org.culturegraph.mf.plumbing.XmlTee
 stream-to-xml	org.culturegraph.mf.xml.SimpleXmlEncoder
 rdf-macros	org.culturegraph.mf.stream.pipe.RdfMacroPipe
 
-batch-log	org.culturegraph.mf.stream.pipe.StreamBatchLogger
-object-batch-log	org.culturegraph.mf.stream.pipe.ObjectBatchLogger
+batch-log	org.culturegraph.mf.monitoring.StreamBatchLogger
+object-batch-log	org.culturegraph.mf.monitoring.ObjectBatchLogger
 batch-reset	org.culturegraph.mf.flowcontrol.StreamBatchResetter
 
 pass-through org.culturegraph.mf.plumbing.IdentityStreamPipe
diff --git a/src/test/java/org/culturegraph/mf/monitoring/ObjectTimerTest.java b/src/test/java/org/culturegraph/mf/monitoring/ObjectTimerTest.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import org.culturegraph.mf.framework.helpers.DefaultObjectReceiver;
 import org.junit.Before;
diff --git a/src/test/java/org/culturegraph/mf/monitoring/StreamLoggerTest.java b/src/test/java/org/culturegraph/mf/monitoring/StreamLoggerTest.java
@@ -1,6 +1,5 @@
 /*
  * Copyright 2016 Christoph Böhme
- * Copyright 2013, 2014 Deutsche Nationalbibliothek
  *
  * Licensed under the Apache License, Version 2.0 the "License";
  * you may not use this file except in compliance with the License.
@@ -14,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import static org.mockito.Mockito.inOrder;
 
diff --git a/src/test/java/org/culturegraph/mf/monitoring/StreamTimerTest.java b/src/test/java/org/culturegraph/mf/monitoring/StreamTimerTest.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
+package org.culturegraph.mf.monitoring;
 
 import org.culturegraph.mf.framework.helpers.DefaultStreamReceiver;
 import org.junit.Before;
