mirror of
https://github.com/EDCD/EDDN.git
synced 2025-04-28 14:12:13 +03:00
53 lines
1.2 KiB
Python
53 lines
1.2 KiB
Python
import zlib
|
|
import zmq
|
|
import simplejson
|
|
import sys
|
|
import time
|
|
|
|
"""
|
|
" Configuration
|
|
"""
|
|
__relayEDDN = 'tcp://eddn-relay.elite-markets.net:9500'
|
|
__timeoutEDDN = 600000
|
|
|
|
|
|
|
|
"""
|
|
" Start
|
|
"""
|
|
def main():
|
|
context = zmq.Context()
|
|
subscriber = context.socket(zmq.SUB)
|
|
|
|
subscriber.setsockopt(zmq.SUBSCRIBE, b"")
|
|
subscriber.setsockopt(zmq.RCVTIMEO, __timeoutEDDN)
|
|
|
|
while True:
|
|
try:
|
|
subscriber.connect(__relayEDDN)
|
|
|
|
while True:
|
|
__message = subscriber.recv()
|
|
|
|
if __message == False:
|
|
subscriber.disconnect(__relayEDDN)
|
|
break
|
|
|
|
__message = zlib.decompress(__message)
|
|
__json = simplejson.loads(__message)
|
|
|
|
|
|
print (__json)
|
|
sys.stdout.flush()
|
|
|
|
except zmq.ZMQError as e:
|
|
print ('ZMQSocketException: ' + str(e))
|
|
sys.stdout.flush()
|
|
subscriber.disconnect(__relayEDDN)
|
|
time.sleep(5)
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
main()
|