MemoryConsumerFactory.java: Fixed sonar issues 69/64969/1
authorArundathi Patil <arundpil@in.ibm.com>
Thu, 6 Sep 2018 10:08:19 +0000 (15:38 +0530)
committerIBM602-PC0F1E3C\Arundathi <arundpil@in.ibm.com>
Thu, 6 Sep 2018 10:08:27 +0000 (15:38 +0530)
Fixed sonar code-smells/issues across this file.

Issue-ID: DMAAP-745
Change-Id: Ieefda5f0b36ca23ff2406cf298690a1376fedf06
Signed-off-by: Arundathi Patil <arundpil@in.ibm.com>
src/main/java/com/att/dmf/mr/backends/memory/MemoryConsumerFactory.java

index 0c34bfd..237cac8 100644 (file)
@@ -35,6 +35,9 @@ import com.att.dmf.mr.backends.ConsumerFactory;
  */
 public class MemoryConsumerFactory implements ConsumerFactory
 {
+
+       private final MemoryQueue fQueue;
+       
        /**
         * 
         * Initializing constructor
@@ -59,8 +62,6 @@ public class MemoryConsumerFactory implements ConsumerFactory
                return new MemoryConsumer ( topic, consumerGroupId );
        }
 
-       private final MemoryQueue fQueue;
-
        /**
         * 
         * Define nested inner class
@@ -68,6 +69,12 @@ public class MemoryConsumerFactory implements ConsumerFactory
         */
        private class MemoryConsumer implements Consumer
        {
+
+               private final String fTopic;
+               private final String fConsumer;
+               private final long fCreateMs;
+               private long fLastAccessMs;
+               
                /**
                 * 
                 * Initializing MemoryConsumer constructor 
@@ -93,11 +100,6 @@ public class MemoryConsumerFactory implements ConsumerFactory
                        return fQueue.get ( fTopic, fConsumer );
                }
 
-               private final String fTopic;
-               private final String fConsumer;
-               private final long fCreateMs;
-               private long fLastAccessMs;
-
                @Override
                public boolean close() {
                        //Nothing to close/clean up.
@@ -168,7 +170,7 @@ public class MemoryConsumerFactory implements ConsumerFactory
         */
        public Collection<? extends Consumer> getConsumers ()
        {
-               return new ArrayList<MemoryConsumer> ();
+               return new ArrayList<> ();
        }
 
        @Override