ZMQ Publisher removed

ZMQ Publisher removed to allow concurrent use of the scripts.
In short term, we would replace all publishing part within AIL
into pub-sub Redis to avoid ZMQ limitation.
pull/23/head
Alexandre Dulaunoy 2014-08-26 14:38:49 +02:00
parent 264da48768
commit 3b499a2ec8
1 changed files with 2 additions and 7 deletions

View File

@ -26,11 +26,6 @@ if __name__ == "__main__":
h = Helper.Redis_Queues(config_section, config_channel, subscriber_name)
# Publisher
pub_config_section = "PubSub_Url"
pub_config_channel = 'channel'
h.zmq_pub(pub_config_section, pub_config_channel)
# Subscriber
h.zmq_sub(config_section)
@ -65,7 +60,7 @@ if __name__ == "__main__":
port, resource_path, query_string, f1, f2, f3, \
f4 = x
domains_list.append(domain)
h.zmq_pub_send(str(x))
print (str(x))
publisher.debug('{} Published'.format(x))
if f1 == "onion":
@ -122,4 +117,4 @@ if __name__ == "__main__":
message = h.redis_rpop()
except dns.exception.Timeout:
print "dns.exception.Timeout", A_values
print "dns.exception.Timeout ", hostl