Simple zeromq client that keeps track of dropped messages

client.py

#!/usr/bin/env python

import zmq
import time

def client():
  context = zmq.Context()
  socket = context.socket(zmq.PULL)
  socket.setsockopt(zmq.LINGER, -1)

  socket.connect('tcp://127.0.0.1:8888')
  ctr = 0
  prev = 0
  while 1:
    ctr = int(socket.recv())
    if ctr % 10000 == 0: print ctr
    if ctr - prev != 1:
      print "lost messages " + str(ctr - prev - 1)
    prev = ctr
    time.sleep(0.0001)


if __name__ == "__main__":
  client()