[rabbitmq-discuss] Pika Client error/disconnect

[Laing, Michael]

what's the pika version? -ml


On Mon, Feb 10, 2014 at 12:47 PM, Darren Govoni <darren at ontrenet.com> wrote:

>  Hi,
>   I'm using python celery with RabbitMQ and AMQP. Pika occasionally gives
> this bizarre
> error, from which, there is no recovery.
>
> [2014-02-10 17:16:25,189: ERROR/Worker-20] Socket Error on fd 9: 32
> [2014-02-10 17:16:25,190: WARNING/Worker-20] Traceback (most recent call
> last):
>   File "/home/ubuntu/software/code/gridwave/matrix/bundles/nlp/engine.py",
> line 160, in process_bid
>     workflow.construct(_workflow['workflow'])
>   File
> "/home/ubuntu/software/code/gridwave/matrix/bundles/workflow/celery/__init__.py",
> line 920, in construct
>     self.workflow_broker.publish(wfdoc)
>   File
> "/home/ubuntu/software/code/gridwave/matrix/bundles/messaging/rabbitmq/__init__.py",
> line 131, in publish
>
> self.channel.basic_publish(exchange=self.exchange,routing_key=self.key,body=message)
>   File
> "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py",
> line 540, in basic_publish
>     (properties, body), False)
>   File
> "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py",
> line 1121, in _send_method
>     self.connection.send_method(self.channel_number, method_frame, content)
>   File
> "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py",
> line 249, in send_method
>     self._send_method(channel_number, method_frame, content)
>   File "/usr/local/lib/python2.7/dist-packages/pika/connection.py", line
> 1489, in _send_method
>     self._send_frame(frame.Method(channel_number, method_frame))
>   File
> "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py",
> line 388, in _send_frame
>     super(BlockingConnection, self)._send_frame(frame_value)
>   File "/usr/local/lib/python2.7/dist-packages/pika/connection.py", line
> 1476, in _send_frame
>     self._flush_outbound()
>   File
> "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py",
> line 348, in _flush_outbound
>     if self._handle_write():
>   File
> "/usr/local/lib/python2.7/dist-packages/pika/adapters/base_connection.py",
> line 338, in _handle_write
>     return self._handle_error(error)
>   File
> "/usr/local/lib/python2.7/dist-packages/pika/adapters/base_connection.py",
> line 282, in _handle_error
>     self._handle_disconnect()
>   File
> "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py",
> line 318, in _handle_disconnect
>     self.disconnect()
> AttributeError: 'BlockingConnection' object has no attribute 'disconnect'
>
> Any clues I can look for?
>
> Ubuntu 13.10, 64bit.
>
> thanks,
> Darren
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140210/615a61bd/attachment.html>