Follow sonarcloud advises for better code

- use diamond operator
- use format specifiers instead of string concatenation when logging

Author: dr0i

metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/ObjectPipeDecoupler.java

@@ -49,15 +49,15 @@ public final class ObjectPipeDecoupler<T> implements ObjectPipe<T, ObjectReceive
     private boolean debug;
 
     public ObjectPipeDecoupler() {
-        queue = new LinkedBlockingQueue<Object>(DEFAULT_CAPACITY);
+        queue = new LinkedBlockingQueue<>(DEFAULT_CAPACITY);
     }
 
     public ObjectPipeDecoupler(final int capacity) {
-        queue = new LinkedBlockingQueue<Object>(capacity);
+        queue = new LinkedBlockingQueue<>(capacity);
     }
 
     public ObjectPipeDecoupler(final String capacity) {
-        queue = new LinkedBlockingQueue<Object>(Integer.parseInt(capacity));
+        queue = new LinkedBlockingQueue<>(Integer.parseInt(capacity));
     }
 
     public void setDebug(final boolean debug) {
@@ -73,7 +73,7 @@ public void process(final T obj) {
         try {
             queue.put(obj);
             if (debug) {
-                LOG.info("Current buffer size: " + queue.size());
+                LOG.info("Current buffer size: {}", queue.size());
             }
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();

metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/ObjectThreader.java

@@ -62,7 +62,7 @@ public <R extends ObjectReceiver<T>> R setReceiver(final R receiver) {
 
     @Override
     public Tee<ObjectReceiver<T>> addReceiver(final ObjectReceiver<T> receiver) {
-        LOG.info("Adding thread " + (getReceivers().size() + 1));
+        LOG.info("Adding thread {}", (getReceivers().size() + 1));
         ObjectPipeDecoupler<T> opd = new ObjectPipeDecoupler<>();
         opd.setReceiver(receiver);
         return super.addReceiver(opd);