From f34bc9559c77fcfd1bc20ad586ab3973fe1a7582 Mon Sep 17 00:00:00 2001 From: Athanasius Date: Sat, 12 Mar 2022 11:58:48 +0000 Subject: [PATCH] Monitor: Tweak for zmq changes --- src/eddn/Monitor.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/eddn/Monitor.py b/src/eddn/Monitor.py index 36ec2ad..85432fa 100644 --- a/src/eddn/Monitor.py +++ b/src/eddn/Monitor.py @@ -13,6 +13,8 @@ import simplejson import zmq.green as zmq from bottle import Bottle, request, response from gevent import monkey +from zmq import SUB as ZMQ_SUB +from zmq import SUBSCRIBE as ZMQ_SUBSCRIBE from eddn.conf.Settings import Settings, load_config @@ -197,8 +199,8 @@ class Monitor(Thread): """Handle receiving Gateway messages and recording stats.""" context = zmq.Context() - receiver = context.socket(zmq.SUB) - receiver.setsockopt_string(zmq.SUBSCRIBE, '') + receiver = context.socket(ZMQ_SUB) + receiver.setsockopt_string(ZMQ_SUBSCRIBE, '') for binding in Settings.MONITOR_RECEIVER_BINDINGS: receiver.connect(binding)