metafacture-plumbing/ (main): Fix Checkstyle violations.

Author: blackwinter

metafacture-plumbing/src/main/java/org/metafacture/plumbing/IdentityStreamPipe.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import org.metafacture.framework.FluxCommand;
@@ -33,4 +34,7 @@
 @FluxCommand("pass-through")
 public final class IdentityStreamPipe extends ForwardingStreamPipe {
 
+    public IdentityStreamPipe() {
+    }
+
 }

metafacture-plumbing/src/main/java/org/metafacture/plumbing/ObjectTee.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import org.metafacture.framework.FluxCommand;
@@ -35,12 +36,14 @@
 @In(Object.class)
 @Out(Object.class)
 @FluxCommand("object-tee")
-public final class ObjectTee<T> extends DefaultTee<ObjectReceiver<T>>
-        implements ObjectPipe<T, ObjectReceiver<T>> {
+public final class ObjectTee<T> extends DefaultTee<ObjectReceiver<T>> implements ObjectPipe<T, ObjectReceiver<T>> {
+
+    public ObjectTee() {
+    }
 
     @Override
     public void process(final T obj) {
-        for (ObjectReceiver<T> receiver : getReceivers()) {
+        for (final ObjectReceiver<T> receiver : getReceivers()) {
             receiver.process(obj);
         }
     }

metafacture-plumbing/src/main/java/org/metafacture/plumbing/StreamBatchMerger.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import org.metafacture.framework.FluxCommand;
@@ -44,6 +45,9 @@ public final class StreamBatchMerger extends DefaultStreamPipe<StreamReceiver> {
     private long batchSize = DEFAULT_BATCH_SIZE;
     private long recordCount;
 
+    public StreamBatchMerger() {
+    }
+
     /**
      * Sets the number of records that should be merged into a batch.
      * <p>

metafacture-plumbing/src/main/java/org/metafacture/plumbing/StreamMerger.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import org.metafacture.framework.FluxCommand;
@@ -37,12 +38,14 @@
 @In(StreamReceiver.class)
 @Out(StreamReceiver.class)
 @FluxCommand("merge-same-ids")
-public final class StreamMerger
-        extends DefaultStreamPipe<StreamReceiver> {
+public final class StreamMerger extends DefaultStreamPipe<StreamReceiver> {
 
     private boolean hasRecordsReceived;
     private String currentId = "";
 
+    public StreamMerger() {
+    }
+
     @Override
     public void startRecord(final String identifier) {
         assert !isClosed();

metafacture-plumbing/src/main/java/org/metafacture/plumbing/StreamTee.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import org.metafacture.framework.FluxCommand;
@@ -33,40 +34,42 @@
 @In(StreamReceiver.class)
 @Out(StreamReceiver.class)
 @FluxCommand("stream-tee")
-public final class StreamTee extends DefaultTee<StreamReceiver>
-        implements StreamPipe<StreamReceiver> {
+public final class StreamTee extends DefaultTee<StreamReceiver> implements StreamPipe<StreamReceiver> {
+
+    public StreamTee() {
+    }
 
     @Override
     public void startRecord(final String identifier) {
-        for (StreamReceiver receiver : getReceivers()) {
+        for (final StreamReceiver receiver : getReceivers()) {
             receiver.startRecord(identifier);
         }
     }
 
     @Override
     public void endRecord() {
-        for (StreamReceiver receiver : getReceivers()) {
+        for (final StreamReceiver receiver : getReceivers()) {
             receiver.endRecord();
         }
     }
 
     @Override
     public void startEntity(final String name) {
-        for (StreamReceiver receiver : getReceivers()) {
+        for (final StreamReceiver receiver : getReceivers()) {
             receiver.startEntity(name);
         }
     }
 
     @Override
     public void endEntity() {
-        for (StreamReceiver receiver : getReceivers()) {
+        for (final StreamReceiver receiver : getReceivers()) {
             receiver.endEntity();
         }
     }
 
     @Override
     public void literal(final String name, final String value) {
-        for (StreamReceiver receiver : getReceivers()) {
+        for (final StreamReceiver receiver : getReceivers()) {
             receiver.literal(name, value);
         }
     }

metafacture-plumbing/src/main/java/org/metafacture/plumbing/XmlTee.java

@@ -13,9 +13,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.metafacture.plumbing;
 
-import java.io.IOException;
+package org.metafacture.plumbing;
 
 import org.metafacture.framework.FluxCommand;
 import org.metafacture.framework.XmlPipe;
@@ -24,12 +23,15 @@
 import org.metafacture.framework.annotations.In;
 import org.metafacture.framework.annotations.Out;
 import org.metafacture.framework.helpers.DefaultTee;
+
 import org.xml.sax.Attributes;
 import org.xml.sax.InputSource;
 import org.xml.sax.Locator;
 import org.xml.sax.SAXException;
 import org.xml.sax.SAXParseException;
 
+import java.io.IOException;
+
 /**
  * Sends one {@link XmlReceiver} to two {@link XmlReceiver}s.
  *
@@ -40,7 +42,10 @@
 @In(XmlReceiver.class)
 @Out(XmlReceiver.class)
 @FluxCommand("xml-tee")
-public final class XmlTee extends DefaultTee<XmlReceiver>implements XmlPipe<XmlReceiver> {
+public final class XmlTee extends DefaultTee<XmlReceiver> implements XmlPipe<XmlReceiver> {
+
+    public XmlTee() {
+    }
 
     @Override
     public void characters(final char[] ch, final int start, final int length) throws SAXException {

metafacture-plumbing/src/test/java/org/metafacture/plumbing/IdentityStreamPipeTest.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import static org.mockito.Mockito.inOrder;

metafacture-plumbing/src/test/java/org/metafacture/plumbing/StreamBatchMergerTest.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import org.junit.Before;

metafacture-plumbing/src/test/java/org/metafacture/plumbing/StreamMergerTest.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import static org.mockito.Mockito.inOrder;

metafacture-plumbing/src/test/java/org/metafacture/plumbing/StreamTeeTest.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.plumbing;
 
 import static org.mockito.Mockito.inOrder;