spacepaste

Paste details

reply | raw

  1.  
  2. #!/usr/bin/env python
  4. import traceback
  5. import sys
  6. import zmq
  7. from time import sleep
  9. print "Creating the zmq.Context"
  10. context = zmq.Context()
  12. print "Binding the publisher to the local socket at port 5557"
  13. sender = context.socket(zmq.PUB)
  14. sender.bind("tcp://*:5557")
  16. print "Binding the subscriber to the local socket at port 5557"
  17. receiver = context.socket(zmq.SUB)
  18. receiver.connect("tcp://*:5557")
  20. print "Setting the subscriber option to get only those originating from \"B\""
  21. receiver.setsockopt(zmq.SUBSCRIBE, "B")
  23. print "Waiting a second for the socket to be created."
  24. sleep(1)
  26. print "Sending messages"
  27. for i in range(1,10):
  28. msg = "msg %d" % (i)
  29. env = None
  30. if i % 2 == 0:
  31. env = ["B", msg]
  32. else:
  33. env = ["A", msg]
  34. print "Sending Message: ", env
  35. sender.send_multipart(env)
  37. print "Closing the sender."
  38. sender.close()
  40. failed_attempts = 0
  41. while failed_attempts < 3:
  42. try:
  43. print str(receiver.recv_multipart(zmq.NOBLOCK))
  44. except:
  45. print traceback.format_exception(*sys.exc_info())
  46. failed_attempts += 1
  48. print "Closing the receiver."
  49. receiver.close()
  51. print "Terminating the context."
  52. context.term()
  54. """
  55. Output:
  57. Creating the zmq.Context
  58. Binding the publisher to the local socket at port 5557
  59. Binding the subscriber to the local socket at port 5557
  60. Setting the subscriber option to get only those originating from "B"
  61. Waiting a second for the socket to be created.
  62. Sending messages
  63. Sending Message: ['A', 'msg 1']
  64. Sending Message: ['B', 'msg 2']
  65. Sending Message: ['A', 'msg 3']
  66. Sending Message: ['B', 'msg 4']
  67. Sending Message: ['A', 'msg 5']
  68. Sending Message: ['B', 'msg 6']
  69. Sending Message: ['A', 'msg 7']
  70. Sending Message: ['B', 'msg 8']
  71. Sending Message: ['A', 'msg 9']
  72. Closing the sender.
  73. ['B', 'msg 2']
  74. ['B', 'msg 4']
  75. ['B', 'msg 6']
  76. ['B', 'msg 8']
  77. ['Traceback (most recent call last):\n', ' File "./test.py", line 43, in <module>\n print str(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']
  78. ['Traceback (most recent call last):\n', ' File "./test.py", line 43, in <module>\n print str(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']
  79. ['Traceback (most recent call last):\n', ' File "./test.py", line 43, in <module>\n print str(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']
  80. Closing the receiver.
  81. Terminating the context.
  82. """
  83.  
Powered by spacepaste. Paste removal.