[rabbitmq-discuss] Pika and XML-RPC

Mon May 2 07:31:13 BST 2011

Hi all,

using Pika with XML-RPC (in separate threads) leads sometimes to the following 
exception when starting the process and the two threads. Is there a known issue 
for when mixing Pika and XML-RPC?

Process Process-1:
Traceback (most recent call last):
   File "/usr/lib/python2.6/multiprocessing/process.py", line 232, in _bootstrap
     self.run()
   File "/usr/lib/python2.6/multiprocessing/process.py", line 88, in run
     self._target(*self._args, **self._kwargs)
   File 
"/home/denis/SVN/totemit/trunk/MARGE/RabbitMQ-Redmine-TOTEM/TSP-MARGE-Communication/RabbitMQ/RabbitMQTOTEMLibrary/Python/net/totem/gamelogic/creategamelogicserver.py", 
line 39, in createGameLogicServer
     mystate.connection.ioloop.start()
   File 
"/home/denis/Tmp/Local/Python/pika-0.9.5/pika/adapters/select_connection.py", 
line 124, in start
     self.poller.start()
   File 
"/home/denis/Tmp/Local/Python/pika-0.9.5/pika/adapters/select_connection.py", 
line 374, in start
     self.poll()
   File 
"/home/denis/Tmp/Local/Python/pika-0.9.5/pika/adapters/select_connection.py", 
line 388, in poll
     self._handler(events[0][0], events[0][1])
   File 
"/home/denis/Tmp/Local/Python/pika-0.9.5/pika/adapters/base_connection.py", 
line 134, in _handle_events
     self._handle_read()
   File 
"/home/denis/Tmp/Local/Python/pika-0.9.5/pika/adapters/base_connection.py", 
line 162, in _handle_read
     self._on_data_available(data)
   File "/home/denis/Tmp/Local/Python/pika-0.9.5/pika/connection.py", line 599, 
in _on_data_available
     self._channels[frame.channel_number].transport.deliver(frame)
   File "/home/denis/Tmp/Local/Python/pika-0.9.5/pika/channel.py", line 64, in 
deliver
     self.frame_dispatcher.process(frame)
   File "/home/denis/Tmp/Local/Python/pika-0.9.5/pika/frame.py", line 202, in 
process
     self._handler(frame)
   File "/home/denis/Tmp/Local/Python/pika-0.9.5/pika/frame.py", line 220, in 
_handle_method_frame
     raise NotImplementedError(frame.method.__class__)
NotImplementedError: <class 'pika.spec.DeclareOk'>

Denis