display.py

import zmq, time


def main(addr):
    print addr
    context = zmq.Context(1, 1)
    socket = context.socket(zmq.SUB)

    socket.setsockopt(zmq.SUBSCRIBE, "")
    socket.connect(addr)

    while True:
        msg = socket.recv_pyobj()
        print "%s: %s" % (msg[1], msg[0])

if __name__ == '__main__':
    import sys
    if len(sys.argv) != 2:
        print "usage: display.py <address>"
        raise SystemExit
    main(sys.argv[1])

prompt.py

import zmq


def main(addr, who):
    print addr

    ctx = zmq.Context(1, 1)

    socket = ctx.socket(zmq.PUB)
    socket.connect(addr)

    while True:
        msg = raw_input("%s> " % who)
        assert socket.send_pyobj((msg, who))
        socket.flush()


if __name__ == '__main__':
    import sys
    if len(sys.argv) != 3:
        print "usage: prompt.py <address> <username>"
        raise SystemExit
    main(sys.argv[1], sys.argv[2])