[rabbitmq-discuss] pika exceptions

Gavin M. Roy gmr at myyearbook.com
Sat Jan 29 19:37:29 GMT 2011


Can you send me your stress test app? I'd like to test it.

On Sat, Jan 29, 2011 at 1:28 PM, Marcin Krol <mrkafk at gmail.com> wrote:
> -----BEGIN PGP SIGNED MESSAGE-----
> Hash: SHA1
>
> Hello everyone,
>
> Re "stress test" I wrote about in another mail - even if I increase
> time.sleep pika starts throwing exceptions after a while:
>
>
> Exception in thread Thread-1:
> Traceback (most recent call last):
>  File "/usr/lib/python2.5/threading.py", line 486, in __bootstrap_inner
>    self.run()
>  File "./rc_mt2.py", line 167, in run
>    self.testfun(*self.args, **self.kwargs)
>  File "./rc_mt2.py", line 179, in rpc_testcall
>    repl = rc.call(hello, servnum, rdonly=rdonly)
>  File "./rc_mt2.py", line 133, in call
>    self.setup_distrib(self.node)
>  File "./rc_mt2.py", line 88, in setup_distrib
>    self.res = self.chan.queue_declare(exclusive = True)
>  File "/usr/local/bin/src/pika/pika/spec.py", line 3003, in queue_declare
>    [Queue.DeclareOk])
>  File "/usr/local/bin/src/pika/pika/channel.py", line 186, in _rpc
>    self._ensure()
>  File "/usr/local/bin/src/pika/pika/channel.py", line 84, in _ensure
>    raise ChannelClosed(self.channel_close)
> ChannelClosed: Connection.Close(class_id = 0, method_id = 0, reply_code
> = 540, reply_text = 'Pika: method not implemented: Exchange.DeclareOk')
>
>
>
>
> Exception in thread Thread-4:
> Traceback (most recent call last):
>  File "/usr/lib/python2.5/threading.py", line 486, in __bootstrap_inner
>    self.run()
>  File "./rc_mt2.py", line 167, in run
>    self.testfun(*self.args, **self.kwargs)
>  File "./rc_mt2.py", line 176, in rpc_testcall
>    rc = RPCClient(node, servnum, rdonly)
>  File "./rc_mt2.py", line 66, in __init__
>    self.setup_conn(self.node)
>  File "./rc_mt2.py", line 81, in setup_conn
>    self.conn = pika.AsyncoreConnection(pika.ConnectionParameters(node))
>  File "/usr/local/bin/src/pika/pika/connection.py", line 154, in __init__
>    self.wait_for_open()
>  File "/usr/local/bin/src/pika/pika/connection.py", line 390, in
> wait_for_open
>    self.drain_events()
>  File "/usr/local/bin/src/pika/pika/asyncore_adapter.py", line 119, in
> drain_events
>    loop(count = 1, timeout = timeout)
>  File "/usr/local/bin/src/pika/pika/asyncore_adapter.py", line 169, in loop
>    loop1(map, timeout)
>  File "/usr/local/bin/src/pika/pika/asyncore_adapter.py", line 157, in
> loop1
>    asyncore.loop(timeout = next_event_timeout(timeout), map = map,
> count = 1)
>  File "/usr/lib/python2.5/asyncore.py", line 195, in loop
>    poll_fun(timeout, map)
>  File "/usr/lib/python2.5/asyncore.py", line 121, in poll
>    r, w, e = select.select(r, w, e, timeout)
> error: (9, 'Bad file descriptor')
>
>
> - --
>
> Regards,
> mk
>
> - --
> Premature optimization is the root of all fun.
> -----BEGIN PGP SIGNATURE-----
> Version: GnuPG v1.4.9 (MingW32)
> Comment: Using GnuPG with Mozilla - http://enigmail.mozdev.org/
>
> iQEcBAEBAgAGBQJNRFxPAAoJEFMgHzhQQ7hOeecH/jDgdWoaodWWJToKOft9A1I9
> zv69d/rneamUL0l1pWqScaCQormqlWS3lnIKAz5xclDPPja45YA6RDcWoTM8xjJX
> lO0oe/u5HZ1+tnqautAFvQiN9Rn2YfaQ6b58sRTwGcWNqgjn4Xsq9/LfXeRIvA1h
> wltNPPK/AgupZ5DqDiZIBYorp6FvPNRohB5YPMVhB9osXom7HLU6AaSAQ7JLSi62
> IG/Q7/Z3H0vLhQX9Breob0nC7nTYUVoA6Xmd8qjfPDhU2qwA9Wqeu+4cSVDPSMte
> w2RNqVXG7L8E0Ccu449X7Z4RHLBtsPJ0d/6IhzacupTaLjzZ635GTJ0rOD12M0c=
> =FCP4
> -----END PGP SIGNATURE-----
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>


More information about the rabbitmq-discuss mailing list