minor code cleanup/fixes

Author: brainlag

src/main/java/com/github/brainlag/nsq/NSQCommand.java

@@ -5,10 +5,10 @@
 import java.util.List;
 
 public class NSQCommand {
-    String line;
-    List<byte[]> data = new ArrayList<>();
+    private String line;
+    private List<byte[]> data = new ArrayList<>();
 
-    private NSQCommand() { /** no instances */ }
+    private NSQCommand() { /** no instances */}
 
     public void addBytes(byte[] bytes) {
         data.add(bytes);

src/main/java/com/github/brainlag/nsq/NSQConsumer.java

@@ -70,9 +70,7 @@ public NSQConsumer start() {
             started = true;
             //connect once otherwise we might have to wait one lookupPeriod
             connect();
-            scheduler.scheduleAtFixedRate(() -> {
-                connect();
-            }, lookupPeriod, lookupPeriod, TimeUnit.MILLISECONDS);
+            scheduler.scheduleAtFixedRate(() -> connect(), lookupPeriod, lookupPeriod, TimeUnit.MILLISECONDS);
         }
         return this;
     }

src/test/java/com/github/brainlag/nsq/NSQConsumerTest.java

@@ -21,7 +21,7 @@ public class NSQConsumerTest {
     @Test
     public void testLongRunningConsumer() throws NSQException, TimeoutException, InterruptedException {
         AtomicInteger counter = new AtomicInteger(0);
-        NSQLookup lookup = new DefaultNSQLookup(mapper);
+        NSQLookup lookup = new DefaultNSQLookup();
         lookup.addLookupAddress(Nsq.getNsqLookupdHost(), 4161);
 
         NSQConsumer consumer = new NSQConsumer(lookup, "test1", "testconsumer", (message) -> {