Advertisement
Guest User

Untitled

a guest
Jun 15th, 2016
62
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.57 KB | None | 0 0
  1. from stompy import stomp
  2. from multiprocessing import Process
  3. import json
  4.  
  5. def tmp(q, w, e):
  6. print q, w, e
  7. return
  8.  
  9. s = stomp.Stomp(amq_ip, amq_port)
  10. s.connect(username=amq_user, password=amq_pass)
  11. s.subscribe({'destination':'/queue/%s' % amq_queue, 'ack':'client'})
  12.  
  13. while True:
  14. try:
  15. frame = s.receive_frame()
  16. except:
  17. continue
  18.  
  19. # тут костылирую
  20. # жду советов от гуру, как избавиться
  21. body = json.loads(frame.as_string().split('nn')[1][:-1])
  22.  
  23. p = Process(target=tmp, args=(frame, s, body))
  24. p.daemon = True
  25. p.start()
  26. p.join()
  27.  
  28. Traceback (most recent call last):
  29. File "./tmp.py", line 31, in <module>
  30. p.start()
  31. File "C:Python27libmultiprocessingprocess.py", line 130, in start
  32. self._popen = Popen(self)
  33. File "C:Python27libmultiprocessingforking.py", line 277, in __init__
  34. dump(process_obj, to_child, HIGHEST_PROTOCOL)
  35. File "C:Python27libmultiprocessingforking.py", line 199, in dump
  36. ForkingPickler(file, protocol).dump(obj)
  37. File "C:Python27libpickle.py", line 224, in dump
  38. self.save(obj)
  39. File "C:Python27libpickle.py", line 331, in save
  40. self.save_reduce(obj=obj, *rv)
  41. File "C:Python27libpickle.py", line 425, in save_reduce
  42. save(state)
  43. File "C:Python27libpickle.py", line 286, in save
  44. f(self, obj) # Call unbound method with explicit self
  45. File "C:Python27libpickle.py", line 655, in save_dict
  46. self._batch_setitems(obj.iteritems())
  47. File "C:Python27libpickle.py", line 687, in _batch_setitems
  48. save(v)
  49. File "C:Python27libpickle.py", line 286, in save
  50. f(self, obj) # Call unbound method with explicit self
  51. File "C:Python27libpickle.py", line 554, in save_tuple
  52. save(element)
  53. File "C:Python27libpickle.py", line 331, in save
  54. self.save_reduce(obj=obj, *rv)
  55. File "C:Python27libpickle.py", line 425, in save_reduce
  56. save(state)
  57. File "C:Python27libpickle.py", line 286, in save
  58. f(self, obj) # Call unbound method with explicit self
  59. File "C:Python27libpickle.py", line 655, in save_dict
  60. self._batch_setitems(obj.iteritems())
  61. File "C:Python27libpickle.py", line 687, in _batch_setitems
  62. save(v)
  63. File "C:Python27libpickle.py", line 331, in save
  64. self.save_reduce(obj=obj, *rv)
  65. File "C:Python27libpickle.py", line 425, in save_reduce
  66. save(state)
  67. File "C:Python27libpickle.py", line 286, in save
  68. f(self, obj) # Call unbound method with explicit self
  69. File "C:Python27libpickle.py", line 655, in save_dict
  70. self._batch_setitems(obj.iteritems())
  71. File "C:Python27libpickle.py", line 692, in _batch_setitems
  72. save(v)
  73. File "C:Python27libpickle.py", line 286, in save
  74. f(self, obj) # Call unbound method with explicit self
  75. File "C:Python27libpickle.py", line 731, in save_inst
  76. save(stuff)
  77. File "C:Python27libpickle.py", line 286, in save
  78. f(self, obj) # Call unbound method with explicit self
  79. File "C:Python27libpickle.py", line 655, in save_dict
  80. self._batch_setitems(obj.iteritems())
  81. File "C:Python27libpickle.py", line 687, in _batch_setitems
  82. save(v)
  83. File "C:Python27libpickle.py", line 331, in save
  84. self.save_reduce(obj=obj, *rv)
  85. File "C:Python27libpickle.py", line 425, in save_reduce
  86. save(state)
  87. File "C:Python27libpickle.py", line 286, in save
  88. f(self, obj) # Call unbound method with explicit self
  89. File "C:Python27libpickle.py", line 655, in save_dict
  90. self._batch_setitems(obj.iteritems())
  91. File "C:Python27libpickle.py", line 687, in _batch_setitems
  92. save(v)
  93. File "C:Python27libpickle.py", line 306, in save
  94. rv = reduce(self.proto)
  95. TypeError: can't pickle thread.lock objects
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement