[rabbitmq-discuss] NotImplementedError: <class 'pika.spec.CancelOk'>

Tue Aug 16 12:29:36 BST 2011

On Tue, Aug 16, 2011 at 00:36, Matt Pietrek <mpietrek at hotmail.com> wrote:
> I'm getting the following error from code that used to work without
> error until I did an "apt-get upgrade" today.
>
> This is an Ubuntu 11.04 system running Python 2.7 and Pika 0.95. Any
> clues what's happening?

Nope. Maybe it's just a python installation issue?

Can you try removing pika and installing it again? Or maybe
installing a fresh local copy (for example using venv)?

Cheers,
  Marek

> Traceback (most recent call last):
>  File "/usr/lib/python2.7/threading.py", line 552, in
> __bootstrap_inner
>    self.run()
>  File "ConfigMgr.py", line 101, in run
>    self.channel.start_consuming()
>  File "/usr/local/lib/python2.7/dist-packages/pika/adapters/
> blocking_connection.py", line 293, in start_consuming
>    self.transport.connection.process_data_events()
>  File "/usr/local/lib/python2.7/dist-packages/pika/adapters/
> blocking_connection.py", line 94, in process_data_events
>    self._handle_read()
>  File "/usr/local/lib/python2.7/dist-packages/pika/adapters/
> base_connection.py", line 162, in _handle_read
>    self._on_data_available(data)
>  File "/usr/local/lib/python2.7/dist-packages/pika/connection.py",
> line 599, in _on_data_available
>    self._channels[frame.channel_number].transport.deliver(frame)
>  File "/usr/local/lib/python2.7/dist-packages/pika/channel.py", line
> 64, in deliver
>    self.frame_dispatcher.process(frame)
>  File "/usr/local/lib/python2.7/dist-packages/pika/frame.py", line
> 202, in process
>    self._handler(frame)
>  File "/usr/local/lib/python2.7/dist-packages/pika/frame.py", line
> 220, in _handle_method_frame
>    raise NotImplementedError(frame.method.__class__)
> NotImplementedError: <class 'pika.spec.CancelOk'>
>
> Here's what my code looks like:
>
> class ListenForLongRunningEventCompletion(threading.Thread):
>    def run(self):
>        self.connection =
> pika.BlockingConnection(pika.ConnectionParameters(host=MQ_BINDING))
>        self.channel = self.connection.channel()
>
>        self.channel.queue_declare(queue=RESPONSE_QUEUE_NAME)
>        self.channel.basic_consume(ResponseCallback,
>                              queue=RESPONSE_QUEUE_NAME,
>                              no_ack=True)
>        self.channel.start_consuming()
>
>    def shutdown(self):
>        self.channel.stop_consuming()
>
> def ResponseCallback(ch, method, properties, body):
>    print "Long Running Task response({0})".format(body)
>
> #==============================================================================
> #
> # Main program
> #
> #==============================================================================
>
> if __name__ == '__main__':
>    listener = ListenForLongRunningEventCompletion()
>    listener.start()
>
>    # Main app logic - not important here
>
>    # Shut down the connections we've opened up
>    listener.shutdown()
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>