Merge pull request #29 from garnaud/master

add some logs when lookup fails

Author: brainlag

src/main/java/com/github/brainlag/nsq/lookup/DefaultNSQLookup.java

@@ -11,6 +11,7 @@
 import java.net.URL;
 import java.net.URLEncoder;
 import java.util.Set;
+
 public class DefaultNSQLookup implements NSQLookup {
     Set<String> addresses = Sets.newHashSet();
 
@@ -32,20 +33,20 @@ public Set<ServerAddress> lookup(String topic) {
                 ObjectMapper mapper = new ObjectMapper();
                 String topicEncoded = URLEncoder.encode(topic, Charsets.UTF_8.name());
                 JsonNode jsonNode = mapper.readTree(new URL(addr + "/lookup?topic=" + topicEncoded));
-                LogManager.getLogger(this).debug("Server connection information: " + jsonNode.toString());
+                LogManager.getLogger(this).debug("Server connection information: {}", jsonNode);
                 JsonNode producers = jsonNode.get("data").get("producers");
                 for (JsonNode node : producers) {
                     String host = node.get("broadcast_address").asText();
                     ServerAddress address = new ServerAddress(host, node.get("tcp_port").asInt());
                     addresses.add(address);
                 }
             } catch (IOException e) {
-                LogManager.getLogger(this).warn("Unable to connect to address {}", addr);
+                LogManager.getLogger(this).warn("Unable to connect to address {} for topic {}", addr, topic);
                 LogManager.getLogger(this).debug(e.getMessage());
             }
         }
         if (addresses.isEmpty()) {
-            LogManager.getLogger(this).warn("Unable to connect to any NSQ Lookup servers, servers tried: " + this.addresses.toString());
+            LogManager.getLogger(this).warn("Unable to connect to any NSQ Lookup servers, servers tried: {} on topic: {}", this.addresses, topic);
         }
         return addresses;
     }