Simplified zeromq PUSH/PULL example

pullsink.py

import sys
import time
import zmq

context = zmq.Context()

# Socket to receive messages on
receiver = context.socket(zmq.PULL)
receiver.bind("tcp://*:5558")

while True:
    print receiver.recv()

pushventilator.py

import zmq
import random
import time

context = zmq.Context()

# Socket with direct access to the sink: used to syncronize start of batch
sink = context.socket(zmq.PUSH)
sink.connect("tcp://localhost:5558")

# Initialize random number generator
random.seed()

while True:
    workload = random.randint(1, 100)
    sink.send(str(workload))