keepalive_test.py

#!/usr/bin/env python
#-*- coding: utf-8 -*-

import subprocess
import sys
import zmq

SERVER_ADDRESS = "tcp://suma3pg.tf.local:4505"

print "libzmq-%s" % zmq.zmq_version()
print "pyzmq-%s" % zmq.pyzmq_version()
print "Python-%s" % sys.version

context = zmq.Context()
socket = context.socket(zmq.XSUB)

print("TCP_KEEPALIVE value: %s" % socket.getsockopt(zmq.TCP_KEEPALIVE))

socket.connect(SERVER_ADDRESS)
subprocess.call("netstat -eepto | grep 4505 | grep ESTABLISHED", shell=True)

socket = context.socket(zmq.XSUB)
socket.setsockopt(zmq.TCP_KEEPALIVE, 300)
print("TCP_KEEPALIVE value: %s" % socket.getsockopt(zmq.TCP_KEEPALIVE))

socket.connect("tcp://suma3pg.tf.local:4505")
subprocess.call("netstat -eepto | grep 4505 | grep ESTABLISHED", shell=True)