<div>Hi guys,</div><div><br></div><div>let me start with the obvious: thanks for the great library :) I ran into the same problem as was mentioned here:</div><div><br></div><div>&gt;&nbsp;<a href="http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2011-April/012223.html">http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2011-April/012223.html</a><br></div><div><br></div><div>where one sees below warning when using a Tornadoconnection:</div><div><br></div><div><div>/usr/local/lib/python2.6/dist-packages/pika/connection.py:642: UserWarning: Pika: Write buffer exceeded warning threshold at 1827 bytes and an estimated 53 frames behind</div><div>&nbsp; warn(message % (self.outbound_buffer.size, est_frames_behind))</div></div><div><br></div><div>I tried to follow the first approach (disabling the warning and raising the set_backpressure_multiplier), but that raises another problem:</div><div><br></div><div>ERROR:root:Exception in I/O handler for fd 12<br></div><div>Traceback (most recent call last):</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/tornado/ioloop.py", line 308, in start</div><div>&nbsp; &nbsp; self._handlers[fd](fd, events)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/adapters/base_connection.py", line 134, in _handle_events</div><div>&nbsp; &nbsp; self._handle_read()</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/adapters/base_connection.py", line 162, in _handle_read</div><div>&nbsp; &nbsp; self._on_data_available(data)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/connection.py", line 599, in _on_data_available</div><div>&nbsp; &nbsp; self._channels[frame.channel_number].transport.deliver(frame)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/channel.py", line 64, in deliver</div><div>&nbsp; &nbsp; self.frame_dispatcher.process(frame)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/frame.py", line 202, in process</div><div>&nbsp; &nbsp; self._handler(frame)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/frame.py", line 260, in handler</div><div>&nbsp; &nbsp; finish()</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/frame.py", line 289, in finish</div><div>&nbsp; &nbsp; ''.join(body_fragments)) &nbsp; &nbsp; &nbsp;# Arg 3</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/callback.py", line 124, in process</div><div>&nbsp; &nbsp; callback(*args, **keywords)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/channel.py", line 420, in _on_basic_deliver</div><div>&nbsp; &nbsp; body)</div><div>&nbsp; File "/home/blacklist/llupload/llupload/worker/queue_worker.py", line 198, in process_message</div><div>&nbsp; &nbsp; channel.basic_ack(delivery_tag=method.delivery_tag)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/spec.py", line 2563, in basic_ack</div><div>&nbsp; &nbsp; return self.transport.rpc(Basic.Ack(delivery_tag=delivery_tag, multiple=multiple))</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/channel.py", line 119, in rpc</div><div>&nbsp; &nbsp; self.send_method(method)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/channel.py", line 126, in send_method</div><div>&nbsp; &nbsp; self.connection._send_method(self.channel_number, method, content)</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/connection.py", line 657, in _send_method</div><div>&nbsp; &nbsp; self._send_frame(pika.frame.Method(channel_number, method))</div><div>&nbsp; File "/usr/local/lib/python2.6/dist-packages/pika/connection.py", line 642, in _send_frame</div><div>&nbsp; &nbsp; warn(message % (self.outbound_buffer.size, est_frames_behind))</div><div>TypeError: issubclass() arg 2 must be a class or tuple of classes</div><div><br></div><div>Is this a known problem or am I doing something wrong on my side?</div><div><br></div><div><div>Python 2.6.5 (r265:79063, Apr 16 2010, 13:57:41)&nbsp;<br></div><div>[GCC 4.4.3] on linux2</div><div>&gt;&gt;&gt; import pika<br></div><div>&gt;&gt;&gt; pika.__version__</div><div>'0.9.5'</div></div><div><br></div><div>Any help is highly appreciated!</div><div><br></div><div>thanks,</div><div>Clemens</div><div><br></div>