Test application for PyZQM Issue #141 (https://github.com/zeromq/pyzmq/issues/141).

listener.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import sys
sys.path.append('/home/users/enleth/pyzmq/')
import logging
import zmq


FORMAT = '%(asctime)-15s %(message)s'
logging.basicConfig(format=FORMAT)
log = logging.getLogger()
log.setLevel(logging.DEBUG)


def main():
    # preapre zmq
    addr = 'tcp://127.0.0.1:16666'
    context = zmq.Context()
    sock = context.socket(zmq.SUB)
    sock.connect(addr)
    sock.setsockopt(zmq.SUBSCRIBE, '')

    while True:
        route = sock.recv()
        msg = sock.recv()
        log.info('route: %s; msg: %s', route, msg)

if __name__ == "__main__":
    main()

publisher.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import sys
sys.path.append('/home/users/enleth/pyzmq/')
import logging
import zmq
import time


FORMAT = '%(asctime)-15s %(message)s'
logging.basicConfig(format=FORMAT)
log = logging.getLogger()
log.setLevel(logging.DEBUG)


def main():
    # preapre zmq
    addr = 'tcp://127.0.0.1:16666'
    context = zmq.Context()
    sock = context.socket(zmq.PUB)
    sock.setsockopt(zmq.LINGER, 2)
    sock.setsockopt(zmq.HWM, 0)
    sock.bind(addr)

    # send message
    route = '/my/test'
    idx = 0
    while True:
        msg = 'test! %u' % idx
        log.info('Send message to route %s (addr: %s): %s', route, addr, msg)
        sock.send(route, zmq.SNDMORE)
        sock.send(msg)
        idx += 1
        time.sleep( 60 * 60 * 4 )


if __name__ == "__main__":
    main()

run.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import sys
sys.path.append('/home/users/enleth/pyzmq/')
import logging
import zmq


FORMAT = '%(asctime)-15s %(message)s'
logging.basicConfig(format=FORMAT)
log = logging.getLogger()
log.setLevel(logging.DEBUG)


def main():
    # preapre zmq
    addr = 'tcp://127.0.0.1:16666'
    context = zmq.Context()
    sock = context.socket(zmq.SUB)
    sock.connect(addr)
    sock.setsockopt(zmq.SUBSCRIBE, '')

    while True:
        route = sock.recv()
        msg = sock.recv()
        log.info('route: %s; msg: %s', route, msg)

if __name__ == "__main__":
    main()