<div>
                    It looks like to me that you have a non-standard pika install, perhaps the new debian package?
                </div><div><br></div><div>I say that because I see:</div><div><br></div><div><blockquote type="cite" style="border-left-style: solid; border-left-color: rgb(0, 33, 98); color: rgb(0, 33, 98); border-top-width: 1px; border-right-width: 1px; border-bottom-width: 1px; border-left-width: 1px; margin-left: 0px; padding-left: 10px; padding-right: 0px; margin-right: 0px; "><span><div><div><blockquote type="cite" style="border-left-style: solid; border-left-color: rgb(0, 33, 98); color: rgb(0, 33, 98); border-top-width: 1px; border-right-width: 1px; border-bottom-width: 1px; border-left-width: 1px; margin-left: 0px; padding-left: 10px; padding-right: 0px; margin-right: 0px; "><div><blockquote type="cite" style="border-left-style: solid; border-left-color: rgb(0, 33, 98); color: rgb(0, 33, 98); border-top-width: 1px; border-right-width: 1px; border-bottom-width: 1px; border-left-width: 1px; margin-left: 0px; padding-left: 10px; padding-right: 0px; margin-right: 0px; "><div>/usr/local/lib/python2.7/dist-packages/pika/connection.py</div></blockquote></div></blockquote></div></div></span></blockquote><div>And I'd expect something like:</div><div><br></div><div>/usr/lib/python2.7/site-packages/pika/connection.py</div><div><br></div><div>Can you use slocate or find to see if you have more than one version of pika installed?</div><div><br></div><div>What happens when you run the following in python2.7 interactively?</div><div><br></div><div>import pika</div><div>pika.__version__</div><div>&nbsp;</div></div>
                <div></div>
                 
                <p style="color: #A0A0A8;">On Tuesday, August 16, 2011 at 12:18 PM, Matt Pietrek wrote:</p>
                <blockquote type="cite" style="border-left-style:solid;border-width:1px;margin-left:0px;padding-left:10px;">
                    <span><div><div>Alas, no luck with a Pika reinstall. I did a "pip uninstall" of what was<br>there, verified the files were removed, then "pip install".<br><br>All other aspects of my Pika-based code seem to work. I'm sending and<br>receiving 1000's of messages before shutting down. It's only at shutdown<br>where the problem occurs.<br><br>Does my shutdown sequence look OK? That is, calling<br>channel.stop_consuming() from a different thread than I called<br>.start_consuming on?<br><br><br><br>On 8/16/11 4:29 AM, "Marek Majkowski" &lt;<a href="mailto:majek04@gmail.com">majek04@gmail.com</a>&gt; wrote:<br><br><blockquote type="cite"><div>On Tue, Aug 16, 2011 at 00:36, Matt Pietrek &lt;<a href="mailto:mpietrek@hotmail.com">mpietrek@hotmail.com</a>&gt; wrote:<br><blockquote type="cite"><div>I'm getting the following error from code that used to work without<br>error until I did an "apt-get upgrade" today.<br><br>This is an Ubuntu 11.04 system running Python 2.7 and Pika 0.95. Any<br>clues what's happening?<br></div></blockquote><br>Nope. Maybe it's just a python installation issue?<br><br>Can you try removing pika and installing it again? Or maybe<br>installing a fresh local copy (for example using venv)?<br><br>Cheers,<br> Marek<br><br><blockquote type="cite"><div>Traceback (most recent call last):<br> File "/usr/lib/python2.7/threading.py", line 552, in<br>__bootstrap_inner<br>   self.run()<br> File "ConfigMgr.py", line 101, in run<br>   self.channel.start_consuming()<br> File "/usr/local/lib/python2.7/dist-packages/pika/adapters/<br>blocking_connection.py", line 293, in start_consuming<br>   self.transport.connection.process_data_events()<br> File "/usr/local/lib/python2.7/dist-packages/pika/adapters/<br>blocking_connection.py", line 94, in process_data_events<br>   self._handle_read()<br> File "/usr/local/lib/python2.7/dist-packages/pika/adapters/<br>base_connection.py", line 162, in _handle_read<br>   self._on_data_available(data)<br> File "/usr/local/lib/python2.7/dist-packages/pika/connection.py",<br>line 599, in _on_data_available<br>   self._channels[frame.channel_number].transport.deliver(frame)<br> File "/usr/local/lib/python2.7/dist-packages/pika/channel.py", line<br>64, in deliver<br>   self.frame_dispatcher.process(frame)<br> File "/usr/local/lib/python2.7/dist-packages/pika/frame.py", line<br>202, in process<br>   self._handler(frame)<br> File "/usr/local/lib/python2.7/dist-packages/pika/frame.py", line<br>220, in _handle_method_frame<br>   raise NotImplementedError(frame.method.__class__)<br>NotImplementedError: &lt;class 'pika.spec.CancelOk'&gt;<br><br>Here's what my code looks like:<br><br>class ListenForLongRunningEventCompletion(threading.Thread):<br>   def run(self):<br>       self.connection =<br>pika.BlockingConnection(pika.ConnectionParameters(host=MQ_BINDING))<br>       self.channel = self.connection.channel()<br><br>       self.channel.queue_declare(queue=RESPONSE_QUEUE_NAME)<br>       self.channel.basic_consume(ResponseCallback,<br>                             queue=RESPONSE_QUEUE_NAME,<br>                             no_ack=True)<br>       self.channel.start_consuming()<br><br>   def shutdown(self):<br>       self.channel.stop_consuming()<br><br>def ResponseCallback(ch, method, properties, body):<br>   print "Long Running Task response({0})".format(body)<br><br><br>#========================================================================<br>======<br>#<br># Main program<br>#<br><br>#========================================================================<br>======<br><br>if __name__ == '__main__':<br>   listener = ListenForLongRunningEventCompletion()<br>   listener.start()<br><br>   # Main app logic - not important here<br><br>   # Shut down the connections we've opened up<br>   listener.shutdown()<br>_______________________________________________<br>rabbitmq-discuss mailing list<br><a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br><a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br></div></blockquote></div></blockquote><br><br>_______________________________________________<br>rabbitmq-discuss mailing list<br><a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br><a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br></div></div></span>
                 
                 
                 
                 
                </blockquote>
                 
                <div>
                    <br>
                </div>