Create flowcontrol package

The `flowcontrol` package contains modules for controlling the flow of
stream events and objects in a Metafacture pipeline.

Author: cboehme

src/main/java/org/culturegraph/mf/stream/pipe/CloseSuppressor.java renamed to src/main/java/org/culturegraph/mf/flowcontrol/CloseSuppressor.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.flowcontrol;
 
 import org.culturegraph.mf.framework.FluxCommand;
 import org.culturegraph.mf.framework.ObjectPipe;

src/main/java/org/culturegraph/mf/stream/pipe/ObjectExceptionCatcher.java renamed to src/main/java/org/culturegraph/mf/flowcontrol/ObjectExceptionCatcher.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.flowcontrol;
 
 import java.io.PrintWriter;
 import java.io.StringWriter;

src/main/java/org/culturegraph/mf/stream/pipe/ObjectPipeDecoupler.java renamed to src/main/java/org/culturegraph/mf/flowcontrol/ObjectPipeDecoupler.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.flowcontrol;
 
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;

src/main/java/org/culturegraph/mf/stream/pipe/StreamBatchResetter.java renamed to src/main/java/org/culturegraph/mf/flowcontrol/StreamBatchResetter.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.flowcontrol;
 
 import org.culturegraph.mf.framework.FluxCommand;
 import org.culturegraph.mf.framework.StreamReceiver;

src/main/java/org/culturegraph/mf/stream/pipe/StreamBuffer.java renamed to src/main/java/org/culturegraph/mf/flowcontrol/StreamBuffer.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.flowcontrol;
 
 import java.util.ArrayList;
 import java.util.List;

src/main/java/org/culturegraph/mf/stream/pipe/StreamDeferrer.java renamed to src/main/java/org/culturegraph/mf/flowcontrol/StreamDeferrer.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.flowcontrol;
 
 import org.culturegraph.mf.framework.FluxCommand;
 import org.culturegraph.mf.framework.StreamReceiver;

src/main/java/org/culturegraph/mf/stream/pipe/StreamExceptionCatcher.java renamed to src/main/java/org/culturegraph/mf/flowcontrol/StreamExceptionCatcher.java

@@ -1,7 +1,23 @@
+/*
+ * Copyright 2016 Christoph Böhme
+ *
+ * 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.pipe;
+package org.culturegraph.mf.flowcontrol;
 
 import org.culturegraph.mf.framework.FluxCommand;
 import org.culturegraph.mf.framework.StreamReceiver;

src/main/java/org/culturegraph/mf/metamorph/Entity.java

@@ -21,11 +21,11 @@
 import java.util.Set;
 
 import org.culturegraph.mf.commons.StringUtil;
+import org.culturegraph.mf.flowcontrol.StreamBuffer;
 import org.culturegraph.mf.framework.StreamReceiver;
 import org.culturegraph.mf.metamorph.api.NamedValueReceiver;
 import org.culturegraph.mf.metamorph.api.NamedValueSource;
 import org.culturegraph.mf.metamorph.api.helpers.AbstractFlushingCollect;
-import org.culturegraph.mf.stream.pipe.StreamBuffer;
 
 /**
  * Corresponds to the <code>&lt;entity&gt;</code> tag.

src/main/java/org/culturegraph/mf/metamorph/Filter.java

@@ -16,13 +16,13 @@
 package org.culturegraph.mf.metamorph;
 
 
+import org.culturegraph.mf.flowcontrol.StreamBuffer;
 import org.culturegraph.mf.framework.FluxCommand;
 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.culturegraph.mf.framework.helpers.DefaultStreamPipe;
-import org.culturegraph.mf.stream.pipe.StreamBuffer;
 import org.culturegraph.mf.stream.sink.SingleValue;
 
 /**

src/main/java/org/culturegraph/mf/metamorph/Splitter.java

@@ -19,12 +19,12 @@
 import java.util.HashMap;
 import java.util.Map;
 
+import org.culturegraph.mf.flowcontrol.StreamBuffer;
 import org.culturegraph.mf.framework.StreamPipe;
 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.culturegraph.mf.stream.pipe.StreamBuffer;
 import org.culturegraph.mf.stream.sink.SingleValue;