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

Author: blackwinter

metafacture-monitoring/src/main/java/org/metafacture/monitoring/ObjectBatchLogger.java

@@ -13,10 +13,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.metafacture.monitoring;
 
-import java.util.HashMap;
-import java.util.Map;
+package org.metafacture.monitoring;
 
 import org.metafacture.commons.StringUtil;
 import org.metafacture.framework.FluxCommand;
@@ -25,9 +23,13 @@
 import org.metafacture.framework.annotations.In;
 import org.metafacture.framework.annotations.Out;
 import org.metafacture.framework.helpers.DefaultObjectPipe;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * Writes log info for every BATCHSIZE records.
  *
@@ -60,18 +62,15 @@ public final class ObjectBatchLogger<T> extends DefaultObjectPipe<T, ObjectRecei
     private long batchCount;
 
     public ObjectBatchLogger() {
-        super();
         this.format = DEFAULT_FORMAT;
 
     }
 
     public ObjectBatchLogger(final String format) {
-        super();
         this.format = format;
     }
 
     public ObjectBatchLogger(final String format, final Map<String, String> vars) {
-        super();
         this.format = format;
         this.vars.putAll(vars);
     }

metafacture-monitoring/src/main/java/org/metafacture/monitoring/ObjectLogger.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.monitoring;
 
 import org.metafacture.framework.FluxCommand;
@@ -21,10 +22,10 @@
 import org.metafacture.framework.annotations.In;
 import org.metafacture.framework.annotations.Out;
 import org.metafacture.framework.helpers.DefaultObjectPipe;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
 /**
  * Logs the string representation of every object.
  *
@@ -49,7 +50,6 @@ public ObjectLogger() {
     }
 
     public ObjectLogger(final String logPrefix) {
-        super();
         this.logPrefix = logPrefix;
     }
 

metafacture-monitoring/src/main/java/org/metafacture/monitoring/ObjectTimer.java

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

metafacture-monitoring/src/main/java/org/metafacture/monitoring/StreamBatchLogger.java

@@ -13,10 +13,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.metafacture.monitoring;
 
-import java.util.HashMap;
-import java.util.Map;
+package org.metafacture.monitoring;
 
 import org.metafacture.commons.StringUtil;
 import org.metafacture.framework.FluxCommand;
@@ -25,9 +23,13 @@
 import org.metafacture.framework.annotations.In;
 import org.metafacture.framework.annotations.Out;
 import org.metafacture.framework.helpers.ForwardingStreamPipe;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * Writes log info every {@code batchSize} records.
  *
@@ -73,11 +75,11 @@ public StreamBatchLogger(final String format, final Map<String, String> vars) {
         this.vars.putAll(vars);
     }
 
-    public final void setBatchSize(final int batchSize) {
+    public void setBatchSize(final int batchSize) {
         this.batchSize = batchSize;
     }
 
-    public final long getBatchSize() {
+    public long getBatchSize() {
         return batchSize;
     }
 
@@ -90,12 +92,12 @@ public long getRecordCount() {
     }
 
     @Override
-    public final void endRecord() {
+    public void endRecord() {
         getReceiver().endRecord();
-        recordCount++;
+        ++recordCount;
         recordCount %= batchSize;
         if (recordCount == 0) {
-            batchCount++;
+            ++batchCount;
             writeLog();
         }
     }
@@ -106,7 +108,7 @@ protected void onCloseStream() {
     }
 
     @Override
-    protected final void onResetStream() {
+    protected void onResetStream() {
         recordCount = 0;
         batchCount = 0;
     }

metafacture-monitoring/src/main/java/org/metafacture/monitoring/StreamLogger.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.monitoring;
 
 import org.metafacture.framework.FluxCommand;
@@ -21,10 +22,10 @@
 import org.metafacture.framework.annotations.In;
 import org.metafacture.framework.annotations.Out;
 import org.metafacture.framework.helpers.DefaultStreamPipe;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
 /**
  * Leaves the event stream untouched but logs it to the info log.
  * The {@link StreamReceiver} may be {@code null}.
@@ -49,7 +50,6 @@ public StreamLogger() {
     }
 
     public StreamLogger(final String logPrefix) {
-        super();
         this.logPrefix = logPrefix;
     }
 

metafacture-monitoring/src/main/java/org/metafacture/monitoring/StreamTimer.java

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

metafacture-monitoring/src/main/java/org/metafacture/monitoring/TimerBase.java

@@ -13,15 +13,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.monitoring;
 
 import org.metafacture.commons.TimeUtil;
 import org.metafacture.framework.Receiver;
 import org.metafacture.framework.Sender;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
 /**
  * @author Christoph Böhme
  *
@@ -41,14 +42,13 @@ public class TimerBase<R extends Receiver> implements Sender<R> {
     private R receiver;
 
     protected TimerBase(final String logPrefix) {
-        super();
         this.logPrefix = logPrefix;
     }
 
     @Override
-    public final <S extends R> S setReceiver(final S receiver) {
-        this.receiver = receiver;
-        return receiver;
+    public final <S extends R> S setReceiver(final S newReceiver) {
+        receiver = newReceiver;
+        return newReceiver;
     }
 
     public final R getReceiver() {
@@ -69,12 +69,12 @@ public final void closeStream() {
         final long averageDuration;
         if (count > 0) {
             averageDuration = cumulativeDuration / count;
-        } else {
+        }
+        else {
             averageDuration = 0;
         }
-        LOG.info(logPrefix
-                + String.format("Executions: %d; Cumulative duration: %s; Average duration: %s", Long.valueOf(count),
-                        TimeUtil.formatDuration(cumulativeDuration), TimeUtil.formatDuration(averageDuration)));
+        LOG.info(logPrefix + String.format("Executions: %d; Cumulative duration: %s; Average duration: %s", Long.valueOf(count),
+                    TimeUtil.formatDuration(cumulativeDuration), TimeUtil.formatDuration(averageDuration)));
         startMeasurement();
         if (receiver != null) {
             receiver.closeStream();
@@ -86,7 +86,7 @@ protected final void startMeasurement() {
         startTime = System.nanoTime();
     }
 
-    protected final void stopMeasurement(){
+    protected final void stopMeasurement() {
         stopMeasurement("Execution %1$d:");
     }
 

metafacture-monitoring/src/test/java/org/metafacture/monitoring/ObjectTimerTest.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.monitoring;
 
 import org.junit.Before;
@@ -41,7 +42,8 @@ private static final class BenchmarkedModule extends DefaultObjectReceiver<Strin
         public void process(final String obj) {
             try {
                 Thread.sleep(getDuration());
-            } catch (final InterruptedException e) {
+            }
+            catch (final InterruptedException e) {
                 return;
             }
         }

metafacture-monitoring/src/test/java/org/metafacture/monitoring/StreamLoggerTest.java

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

metafacture-monitoring/src/test/java/org/metafacture/monitoring/StreamTimerTest.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.metafacture.monitoring;
 
 import org.junit.Before;
@@ -41,7 +42,8 @@ private static final class BenchmarkedModule extends DefaultStreamReceiver {
         public void startRecord(final String id) {
             try {
                 Thread.sleep(getDuration());
-            } catch (final InterruptedException e) {
+            }
+            catch (final InterruptedException e) {
                 return;
             }
         }