Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from stompy import stomp
- from multiprocessing import Process
- import json
- def tmp(q, w, e):
- print q, w, e
- return
- s = stomp.Stomp(amq_ip, amq_port)
- s.connect(username=amq_user, password=amq_pass)
- s.subscribe({'destination':'/queue/%s' % amq_queue, 'ack':'client'})
- while True:
- try:
- frame = s.receive_frame()
- except:
- continue
- # тут костылирую
- # жду советов от гуру, как избавиться
- body = json.loads(frame.as_string().split('nn')[1][:-1])
- p = Process(target=tmp, args=(frame, s, body))
- p.daemon = True
- p.start()
- p.join()
- Traceback (most recent call last):
- File "./tmp.py", line 31, in <module>
- p.start()
- File "C:Python27libmultiprocessingprocess.py", line 130, in start
- self._popen = Popen(self)
- File "C:Python27libmultiprocessingforking.py", line 277, in __init__
- dump(process_obj, to_child, HIGHEST_PROTOCOL)
- File "C:Python27libmultiprocessingforking.py", line 199, in dump
- ForkingPickler(file, protocol).dump(obj)
- File "C:Python27libpickle.py", line 224, in dump
- self.save(obj)
- File "C:Python27libpickle.py", line 331, in save
- self.save_reduce(obj=obj, *rv)
- File "C:Python27libpickle.py", line 425, in save_reduce
- save(state)
- File "C:Python27libpickle.py", line 286, in save
- f(self, obj) # Call unbound method with explicit self
- File "C:Python27libpickle.py", line 655, in save_dict
- self._batch_setitems(obj.iteritems())
- File "C:Python27libpickle.py", line 687, in _batch_setitems
- save(v)
- File "C:Python27libpickle.py", line 286, in save
- f(self, obj) # Call unbound method with explicit self
- File "C:Python27libpickle.py", line 554, in save_tuple
- save(element)
- File "C:Python27libpickle.py", line 331, in save
- self.save_reduce(obj=obj, *rv)
- File "C:Python27libpickle.py", line 425, in save_reduce
- save(state)
- File "C:Python27libpickle.py", line 286, in save
- f(self, obj) # Call unbound method with explicit self
- File "C:Python27libpickle.py", line 655, in save_dict
- self._batch_setitems(obj.iteritems())
- File "C:Python27libpickle.py", line 687, in _batch_setitems
- save(v)
- File "C:Python27libpickle.py", line 331, in save
- self.save_reduce(obj=obj, *rv)
- File "C:Python27libpickle.py", line 425, in save_reduce
- save(state)
- File "C:Python27libpickle.py", line 286, in save
- f(self, obj) # Call unbound method with explicit self
- File "C:Python27libpickle.py", line 655, in save_dict
- self._batch_setitems(obj.iteritems())
- File "C:Python27libpickle.py", line 692, in _batch_setitems
- save(v)
- File "C:Python27libpickle.py", line 286, in save
- f(self, obj) # Call unbound method with explicit self
- File "C:Python27libpickle.py", line 731, in save_inst
- save(stuff)
- File "C:Python27libpickle.py", line 286, in save
- f(self, obj) # Call unbound method with explicit self
- File "C:Python27libpickle.py", line 655, in save_dict
- self._batch_setitems(obj.iteritems())
- File "C:Python27libpickle.py", line 687, in _batch_setitems
- save(v)
- File "C:Python27libpickle.py", line 331, in save
- self.save_reduce(obj=obj, *rv)
- File "C:Python27libpickle.py", line 425, in save_reduce
- save(state)
- File "C:Python27libpickle.py", line 286, in save
- f(self, obj) # Call unbound method with explicit self
- File "C:Python27libpickle.py", line 655, in save_dict
- self._batch_setitems(obj.iteritems())
- File "C:Python27libpickle.py", line 687, in _batch_setitems
- save(v)
- File "C:Python27libpickle.py", line 306, in save
- rv = reduce(self.proto)
- TypeError: can't pickle thread.lock objects
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement