spacepaste

Paste details

reply | raw

  1.  
  2. #!/usr/bin/env python
  4. import traceback
  5. import sys
  7. import zmq
  8. from time import sleep
  10. context = zmq.Context()
  11. context2 = zmq.Context()
  13. sender = context.socket(zmq.PUB)
  14. sender.bind("tcp://*:5557")
  16. receiver = context2.socket(zmq.SUB)
  17. receiver.connect("tcp://localhost:5557")
  18. receiver.setsockopt(zmq.SUBSCRIBE, "B")
  20. for i in range(1,10):
  21. msg = "msg %d" % (i)
  22. env = None
  23. if i % 2 == 0:
  24. env = ["B", msg]
  25. else:
  26. env = ["A", msg]
  27. print "Send Message: ", env
  28. sender.send_multipart(env)
  29. sender.close()
  31. timeout = 0
  32. while timeout < 10:
  33. try:
  34. print receiver.recv_multipart(zmq.NOBLOCK)
  35. except:
  36. print traceback.format_exception(*sys.exc_info())
  37. timeout += 1
  38. sleep(2)
  40. """
  41. Output:
  43. Send Message: ['A', 'msg 1']
  44. Send Message: ['B', 'msg 2']
  45. Send Message: ['A', 'msg 3']
  46. Send Message: ['B', 'msg 4']
  47. Send Message: ['A', 'msg 5']
  48. Send Message: ['B', 'msg 6']
  49. Send Message: ['A', 'msg 7']
  50. Send Message: ['B', 'msg 8']
  51. Send Message: ['A', 'msg 9']
  52. ['Traceback (most recent call last):\n', ' File "./test.py", line 33, in <module>\n print receiver.recv_multipart(zmq.NOBLOCK)\n', ' File "socket.pyx", line 611, in zmq.core.socket.Socket.recv_multipart (zmq/core/socket.c:5181)\n', ' File "socket.pyx", line 514, in zmq.core.socket.Socket.recv (zmq/core/socket.c:4811)\n', ' File "socket.pyx", line 548, in zmq.core.socket.Socket.recv (zmq/core/socket.c:4673)\n', ' File "socket.pyx", line 99, in zmq.core.socket._recv_copy (zmq/core/socket.c:1344)\n', 'ZMQError: Resource temporarily unavailable\n']
  53. ['Traceback (most recent call last):\n', ' File "./test.py", line 33, in <module>\n print receiver.recv_multipart(zmq.NOBLOCK)\n', ' File "socket.pyx", line 611, in zmq.core.socket.Socket.recv_multipart (zmq/core/socket.c:5181)\n', ' File "socket.pyx", line 514, in zmq.core.socket.Socket.recv (zmq/core/socket.c:4811)\n', ' File "socket.pyx", line 548, in zmq.core.socket.Socket.recv (zmq/core/socket.c:4673)\n', ' File "socket.pyx", line 99, in zmq.core.socket._recv_copy (zmq/core/socket.c:1344)\n', 'ZMQError: Resource temporarily unavailable\n']
  54. ['Traceback (most recent call last):\n', ' File "./test.py", line 33, in <module>\n print receiver.recv_multipart(zmq.NOBLOCK)\n', ' File "socket.pyx", line 611, in zmq.core.socket.Socket.recv_multipart (zmq/core/socket.c:5181)\n', ' File "socket.pyx", line 514, in zmq.core.socket.Socket.recv (zmq/core/socket.c:4811)\n', ' File "socket.pyx", line 548, in zmq.core.socket.Socket.recv (zmq/core/socket.c:4673)\n', ' File "socket.pyx", line 99, in zmq.core.socket._recv_copy (zmq/core/socket.c:1344)\n', 'ZMQError: Resource temporarily unavailable\n']
  55. ^CTraceback (most recent call last):
  56. File "./test.py", line 37, in <module>
  57. sleep(2)
  58. KeyboardInterrupt
  59. """
  60.  
Powered by spacepaste. Paste removal.