[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