diff --git a/reader.py b/reader.py index 8e275b3..8112387 100644 --- a/reader.py +++ b/reader.py @@ -76,7 +76,7 @@ def _query_lookupd(self, lookupd): for producer in producers: self.connect_to_nsqd( - producer['address'], + producer.get('address') or producer['hostname'], producer['tcp_port'], producer['http_port'] )