1 class Queue(object):
 2     def __init__(self):
 3         self.lock = Lock()
 4         self.queue = []
 5 
 6     def pop(self):
 7         with self.lock:
 8             return self.queue.pop(0)
 9 
10     def push(self, v):
11         with self.lock:
12             self.queue.append(v)

1 channel.exchange_declare(
2     exchange='fest-exchange',
3     type='direct')

1 channel.queue_declare(
2     queue="fest-queue",
3     durable=True,
4     auto_delete=False)

1 channel.queue_bind(
2     queue='fest-queue',
3     exchange='fest-exchange')

1 def handle_delivery(channel,
2     method_frame, header_frame, body):
3     # Process the message
4     log.debug('Got message with data: %s',
5               body)
6 
7 channel.basic_consume(
8     handle_delivery, queue='fest-queue')

1 import zmq, datetime, time
2 
3 ctx = zmq.Context()
4 socket = ctx.socket(zmq.PUB)
5 socket.bind("tcp://*:5555")
6 
7 for i in range(10000):
8     socket.send('Time is %s' % datetime.datetime.now())
9     time.sleep(1)

1 import org.zeromq.ZMQ
2 
3 val c = ZMQ.context(2)
4 val s = c.socket(ZMQ.PUSH)
5 s.bind("tcp://*:5556")
6 1 to 10 foreach {i =>
7     s.send("Hello %s".format(i).getBytes(),
8            0) // flags
9 }