dead lock when calling basic.consume fucntion

[agoragames]

dead lock when calling basic.consume fucntion

[simomo]

After I interrupted blocked process, I got this tracebak:

^CTraceback (most recent call last): 
  File "/root/py_envs/staging_tcp_server/local/lib/python2.7/site-packages/gevent/greenlet.py", line 327, in run
    result = self._run(*self.args, **self.kwargs) 
  File "tcp_server.py", line 198, in _handle 
    queue_name, exchange_name, fanout_exchange_name, routing_key_p2p, routing_key_p2g = prepare_rmq_things(doctor_id, client_id, token, socket, sock_write_lock)
  File "tcp_server.py", line 127, in prepare_rmq_things
    rmq_ch.basic.consume(queue_name, wrapper_rmq_msg_handler, consumer_tag=queue_name)
  File "/root/py_envs/staging_tcp_server/local/lib/python2.7/site-packages/haigha/classes/basic_class.py", line 101, in consume
    self.channel.add_synchronous_cb( self._recv_consume_ok )
  File "/root/py_envs/staging_tcp_server/local/lib/python2.7/site-packages/haigha/channel.py", line 295, in add_synchronous_cb
    self.connection.read_frames()
KeyboardInterrupt
<Greenlet at 0x2664f50: _handle(<socket at 0x27cd9d0 fileno=16 sock=> failed with KeyboardInterrupt

It looks like self.connection.read_frames() blocked.

[simomo]

I think I find the root cause, basic.consume will block, if binding same consumer_tag two times.
Because rabbitmq server will thought it as error.