add topic in debug logs when lookup fails · cssword/JavaNSQClient@47dfc26 · GitHub

cssword / JavaNSQClient Public

forked from brainlag/JavaNSQClient

• Notifications You must be signed in to change notification settings
• Fork 0
• Star 0

• Code
• Pull requests
• Actions
• Projects
• Security and quality
• Insights

Additional navigation options

Commit 47dfc26

Browse filesBrowse the repository at this point in the historyBrowse files

Guillaume Arnaud

committed

add topic in debug logs when lookup fails

1 parent 4849b02 commit 47dfc26
Copy full SHA for 47dfc26

1 file changed

+3-2Lines changed: 3 additions & 2 deletions

File tree

Expand file treeCollapse file tree

Open diff view settings

Filter options

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

Expand file treeCollapse file tree

Open diff view settings

Collapse file

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

Copy file name to clipboardExpand all lines: src/main/java/com/github/brainlag/nsq/lookup/DefaultNSQLookup.java

+3-2Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
@@ -11,6 +11,7 @@
11	11	import java.net.URL;
12	12	import java.net.URLEncoder;
13	13	import java.util.Set;
	14	+
14	15	public class DefaultNSQLookup implements NSQLookup {
15	16	Set<String> addresses = Sets.newHashSet();
16	17
@@ -40,12 +41,12 @@ public Set<ServerAddress> lookup(String topic) {
40	41	addresses.add(address);
41	42	}
42	43	} catch (IOException e) {
43		- LogManager.getLogger(this).warn("Unable to connect to address {}", addr);
	44	+ LogManager.getLogger(this).warn("Unable to connect to address {} for topic {}", addr, topic);
44	45	LogManager.getLogger(this).debug(e.getMessage());
45	46	}
46	47	}
47	48	if (addresses.isEmpty()) {
48		- LogManager.getLogger(this).warn("Unable to connect to any NSQ Lookup servers, servers tried: " + this.addresses.toString());
	49	+ LogManager.getLogger(this).warn("Unable to connect to any NSQ Lookup servers, servers tried: {} on topic: {}", this.addresses, topic);
49	50	}
50	51	return addresses;
51	52	}

0 commit comments

Comments

0 (0)