#!/usr/bin/python

import time
import zmq
context = zmq.Context()
socket_pub = context.socket(zmq.PUB)
socket_pub.bind('tcp://127.0.0.1:5051')
time.sleep(1)
for i in range(0, 10000):
    socket_pub.send('msg %4i'%i)