Last active
August 29, 2015 14:03
-
-
Save noelbk/12adcfe188d9f54f971d to your computer and use it in GitHub Desktop.
test_oslo.py times out waiting for reply
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[root@node-10-35-0-14 ~]# python ./test_oslo.py | |
python ./test_oslo.py | |
2014-07-07 16:31:33,764 8949 139757228312320 /usr/lib64/python2.7/site-packages/stevedore/extension.py:_load_plugins | |
found extension EntryPoint.parse('qpid = oslo.messaging._drivers.impl_qpid:QpidDriver') | |
2014-07-07 16:31:33,764 8949 139757228312320 /usr/lib64/python2.7/site-packages/stevedore/extension.py:_load_plugins | |
found extension EntryPoint.parse('zmq = oslo.messaging._drivers.impl_zmq:ZmqDriver') | |
2014-07-07 16:31:33,765 8949 139757228312320 /usr/lib64/python2.7/site-packages/stevedore/extension.py:_load_plugins | |
found extension EntryPoint.parse('kombu = oslo.messaging._drivers.impl_rabbit:RabbitDriver') | |
2014-07-07 16:31:33,765 8949 139757228312320 /usr/lib64/python2.7/site-packages/stevedore/extension.py:_load_plugins | |
found extension EntryPoint.parse('rabbit = oslo.messaging._drivers.impl_rabbit:RabbitDriver') | |
2014-07-07 16:31:33,909 8949 139757228312320 /usr/lib64/python2.7/site-packages/stevedore/extension.py:_load_plugins | |
found extension EntryPoint.parse('fake = oslo.messaging._drivers.impl_fake:FakeDriver') | |
2014-07-07 16:31:33,929 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/connection.py:_start | |
Start from server, version: 0.9, properties: {u'information': u'Licensed under the MPL. See http://www.rabbitmq.com/', u'product': u'RabbitMQ', u'copyright': u'Copyright (C) 2007-2013 VMware, Inc.', u'capabilities': {u'exchange_exchange_bindings': True, u'consumer_cancel_notify': True, u'publisher_confirms': True, u'basic.nack': True}, u'platform': u'Erlang/OTP', u'version': u'3.1.3'}, mechanisms: [u'PLAIN', u'AMQPLAIN'], locales: [u'en_US'] | |
2014-07-07 16:31:33,931 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/connection.py:_open_ok | |
Open OK! | |
2014-07-07 16:31:33,931 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/channel.py:__init__ | |
using channel_id: 1 | |
2014-07-07 16:31:33,932 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/channel.py:_open_ok | |
Channel open | |
2014-07-07 16:31:33,933 8949 139757228312320 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/impl_rabbit.py:_connect | |
Connected to AMQP server on 10.35.0.3:5672 | |
2014-07-07 16:31:33,933 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] exchange_declare(nowait=False, exchange='openstack', durable=False, passive=False, arguments=None, type='topic', auto_delete=False) | |
2014-07-07 16:31:33,934 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] queue_declare(passive=False, nowait=False, exclusive=False, durable=False, queue='will_hang_on_second_usage', arguments={}, auto_delete=False) | |
2014-07-07 16:31:33,935 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] queue_bind(queue='will_hang_on_second_usage', arguments=None, nowait=False, routing_key='will_hang_on_second_usage', exchange='openstack') | |
2014-07-07 16:31:33,936 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] exchange_declare(nowait=False, exchange='openstack', durable=False, passive=False, arguments=None, type='topic', auto_delete=False) | |
2014-07-07 16:31:33,937 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] queue_declare(passive=False, nowait=False, exclusive=False, durable=False, queue='will_hang_on_second_usage.None', arguments={}, auto_delete=False) | |
2014-07-07 16:31:33,937 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] queue_bind(queue='will_hang_on_second_usage.None', arguments=None, nowait=False, routing_key='will_hang_on_second_usage.None', exchange='openstack') | |
2014-07-07 16:31:33,939 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] exchange_declare(nowait=False, exchange='will_hang_on_second_usage_fanout', durable=False, passive=False, arguments=None, type='fanout', auto_delete=True) | |
2014-07-07 16:31:33,940 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] queue_declare(passive=False, nowait=False, exclusive=False, durable=False, queue='will_hang_on_second_usage_fanout_805d11545c784cf983929e148188feff', arguments={}, auto_delete=True) | |
2014-07-07 16:31:33,942 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] queue_bind(queue='will_hang_on_second_usage_fanout_805d11545c784cf983929e148188feff', arguments=None, nowait=False, routing_key='will_hang_on_second_usage', exchange='will_hang_on_second_usage_fanout') | |
2014-07-07 16:31:33,943 8949 139757120747264 ./test_oslo.py:send_main | |
sending msg | |
2014-07-07 16:31:33,944 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] basic_consume(queue='will_hang_on_second_usage', consumer_tag='1', nowait=True, no_ack=False, callback=<function _callback at 0x7f1bc5ccd410>) | |
2014-07-07 16:31:33,944 8949 139757120747264 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/amqpdriver.py:_send | |
MSG_ID is 289ca319feb34fbc9f6da8e756a4185a | |
2014-07-07 16:31:33,945 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] basic_consume(queue='will_hang_on_second_usage.None', consumer_tag='2', nowait=True, no_ack=False, callback=<function _callback at 0x7f1bc5ccd488>) | |
2014-07-07 16:31:33,962 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] basic_consume(queue='will_hang_on_second_usage_fanout_805d11545c784cf983929e148188feff', consumer_tag='3', nowait=False, no_ack=False, callback=<function _callback at 0x7f1bc5ccd050>) | |
2014-07-07 16:31:33,963 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/connection.py:_start | |
Start from server, version: 0.9, properties: {u'information': u'Licensed under the MPL. See http://www.rabbitmq.com/', u'product': u'RabbitMQ', u'copyright': u'Copyright (C) 2007-2013 VMware, Inc.', u'capabilities': {u'exchange_exchange_bindings': True, u'consumer_cancel_notify': True, u'publisher_confirms': True, u'basic.nack': True}, u'platform': u'Erlang/OTP', u'version': u'3.1.3'}, mechanisms: [u'PLAIN', u'AMQPLAIN'], locales: [u'en_US'] | |
2014-07-07 16:31:33,965 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/connection.py:_open_ok | |
Open OK! | |
2014-07-07 16:31:33,965 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] message_to_python(<amqp.basic_message.Message object at 0x7f1bc5cc9ed0>) | |
2014-07-07 16:31:33,965 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/channel.py:__init__ | |
using channel_id: 1 | |
2014-07-07 16:31:33,965 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
message_to_python.body=u'{"oslo.message": "{\\"_unique_id\\": \\"bcf170fd36914aefa1edd3728ca8baf2\\", \\"_msg_id\\": \\"8f9806ad393a4754a65578c386849651\\", \\"_context_context\\": true, \\"send\\": 1, \\"_reply_q\\": \\"reply_5299067755cc40ae8e0d744dbdd58ba3\\"}", "oslo.version": "2.0"}' | |
2014-07-07 16:31:33,966 8949 139757228312320 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/common.py:_safe_log | |
received {u'_unique_id': u'bcf170fd36914aefa1edd3728ca8baf2', u'_msg_id': u'8f9806ad393a4754a65578c386849651', u'_context_context': True, u'send': 1, u'_reply_q': u'reply_5299067755cc40ae8e0d744dbdd58ba3'} | |
2014-07-07 16:31:33,966 8949 139757228312320 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/common.py:_safe_log | |
unpacked context: {'context': True} | |
2014-07-07 16:31:33,966 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/channel.py:_open_ok | |
Channel open | |
2014-07-07 16:31:33,967 8949 139757228312320 ./test_oslo.py:test | |
received msg=<oslo.messaging._drivers.amqpdriver.AMQPIncomingMessage object at 0x7f1bc5cd0490> | |
2014-07-07 16:31:33,967 8949 139757120747264 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/impl_rabbit.py:_connect | |
Connected to AMQP server on 10.35.0.3:5672 | |
2014-07-07 16:31:33,967 8949 139757120747264 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] exchange_declare(nowait=False, exchange='reply_dfcf366e4a7c4122a3c86749370858a4', durable=False, passive=False, arguments=None, type='direct', auto_delete=True) | |
2014-07-07 16:31:33,968 8949 139757120747264 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] queue_declare(passive=False, nowait=False, exclusive=False, durable=False, queue='reply_dfcf366e4a7c4122a3c86749370858a4', arguments={}, auto_delete=True) | |
2014-07-07 16:31:33,970 8949 139757120747264 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] queue_bind(queue='reply_dfcf366e4a7c4122a3c86749370858a4', arguments=None, nowait=False, routing_key='reply_dfcf366e4a7c4122a3c86749370858a4', exchange='reply_dfcf366e4a7c4122a3c86749370858a4') | |
2014-07-07 16:31:33,971 8949 139757120747264 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/amqp.py:_add_unique_id | |
UNIQUE_ID is 86e91969b13c48fc806f4b1ae3ae3718. | |
2014-07-07 16:31:33,987 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/connection.py:_start | |
Start from server, version: 0.9, properties: {u'information': u'Licensed under the MPL. See http://www.rabbitmq.com/', u'product': u'RabbitMQ', u'copyright': u'Copyright (C) 2007-2013 VMware, Inc.', u'capabilities': {u'exchange_exchange_bindings': True, u'consumer_cancel_notify': True, u'publisher_confirms': True, u'basic.nack': True}, u'platform': u'Erlang/OTP', u'version': u'3.1.3'}, mechanisms: [u'PLAIN', u'AMQPLAIN'], locales: [u'en_US'] | |
2014-07-07 16:31:33,989 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/connection.py:_open_ok | |
Open OK! | |
2014-07-07 16:31:33,989 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/channel.py:__init__ | |
using channel_id: 1 | |
2014-07-07 16:31:33,990 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/channel.py:_open_ok | |
Channel open | |
2014-07-07 16:31:33,990 8949 139757120747264 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/impl_rabbit.py:_connect | |
Connected to AMQP server on 10.35.0.3:5672 | |
2014-07-07 16:31:33,990 8949 139757120747264 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] exchange_declare(nowait=False, exchange='openstack', durable=False, passive=False, arguments=None, type='topic', auto_delete=False) | |
2014-07-07 16:31:33,991 8949 139757120747264 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] prepare_message('{"oslo.message": "{\\"_unique_id\\": \\"86e91969b13c48fc806f4b1ae3ae3718\\", \\"_msg_id\\": \\"289ca319feb34fbc9f6da8e756a4185a\\", \\"_context_context\\": true, \\"send\\": 1, \\"_reply_q\\": \\"reply_dfcf366e4a7c4122a3c86749370858a4\\"}", "oslo.version": "2.0"}', 0, 'application/json', 'utf-8', {'ttl': 10000}, {'delivery_mode': 2}) | |
2014-07-07 16:31:33,991 8949 139757120747264 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] _basic_publish(<amqp.basic_message.Message object at 0x7f1bc55c0650>, mandatory=False, routing_key='will_hang_on_second_usage', immediate=False, exchange='openstack') | |
2014-07-07 16:31:33,993 8949 139757120747264 /usr/lib64/python2.7/site-packages/amqp/channel.py:_do_close | |
Closed channel #1 | |
2014-07-07 16:31:33,993 8949 139757120747264 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] basic_consume(queue='reply_dfcf366e4a7c4122a3c86749370858a4', consumer_tag='1', nowait=False, no_ack=False, callback=<function _callback at 0x7f1bc5ccd320>) | |
2014-07-07 16:31:34,985 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/connection.py:_start | |
Start from server, version: 0.9, properties: {u'information': u'Licensed under the MPL. See http://www.rabbitmq.com/', u'product': u'RabbitMQ', u'copyright': u'Copyright (C) 2007-2013 VMware, Inc.', u'capabilities': {u'exchange_exchange_bindings': True, u'consumer_cancel_notify': True, u'publisher_confirms': True, u'basic.nack': True}, u'platform': u'Erlang/OTP', u'version': u'3.1.3'}, mechanisms: [u'PLAIN', u'AMQPLAIN'], locales: [u'en_US'] | |
2014-07-07 16:31:34,986 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/connection.py:_open_ok | |
Open OK! | |
2014-07-07 16:31:34,987 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/channel.py:__init__ | |
using channel_id: 1 | |
2014-07-07 16:31:34,988 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/channel.py:_open_ok | |
Channel open | |
2014-07-07 16:31:34,988 8949 139757228312320 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/impl_rabbit.py:_connect | |
Connected to AMQP server on 10.35.0.3:5672 | |
2014-07-07 16:31:34,989 8949 139757228312320 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/amqp.py:_add_unique_id | |
UNIQUE_ID is 945d805e1e5d426e8e1f99d73f86c93b. | |
2014-07-07 16:31:34,989 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] exchange_declare(nowait=False, exchange=u'reply_5299067755cc40ae8e0d744dbdd58ba3', durable=False, passive=False, arguments=None, type='direct', auto_delete=True) | |
2014-07-07 16:31:34,991 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] prepare_message('{"oslo.message": "{\\"_unique_id\\": \\"945d805e1e5d426e8e1f99d73f86c93b\\", \\"failure\\": null, \\"result\\": {\\"reply\\": 1}, \\"_msg_id\\": \\"8f9806ad393a4754a65578c386849651\\"}", "oslo.version": "2.0"}', 0, 'application/json', 'utf-8', {}, {'delivery_mode': 2}) | |
2014-07-07 16:31:34,991 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] _basic_publish(<amqp.basic_message.Message object at 0x7f1bc5cd0c50>, mandatory=False, routing_key=u'reply_5299067755cc40ae8e0d744dbdd58ba3', immediate=False, exchange=u'reply_5299067755cc40ae8e0d744dbdd58ba3') | |
2014-07-07 16:31:34,992 8949 139757228312320 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/amqp.py:_add_unique_id | |
UNIQUE_ID is caccb0ffe16547a783bd758f0f1fc543. | |
2014-07-07 16:31:34,992 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] exchange_declare(nowait=False, exchange=u'reply_5299067755cc40ae8e0d744dbdd58ba3', durable=False, passive=False, arguments=None, type='direct', auto_delete=True) | |
2014-07-07 16:31:34,993 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] prepare_message('{"oslo.message": "{\\"_unique_id\\": \\"caccb0ffe16547a783bd758f0f1fc543\\", \\"failure\\": null, \\"_msg_id\\": \\"8f9806ad393a4754a65578c386849651\\", \\"result\\": null, \\"ending\\": true}", "oslo.version": "2.0"}', 0, 'application/json', 'utf-8', {}, {'delivery_mode': 2}) | |
2014-07-07 16:31:34,994 8949 139757228312320 /usr/lib64/python2.7/site-packages/kombu/utils/debug.py:__wrapped | |
[Kombu channel:1] _basic_publish(<amqp.basic_message.Message object at 0x7f1bc5cd0bd0>, mandatory=False, routing_key=u'reply_5299067755cc40ae8e0d744dbdd58ba3', immediate=False, exchange=u'reply_5299067755cc40ae8e0d744dbdd58ba3') | |
2014-07-07 16:31:34,995 8949 139757228312320 /usr/lib64/python2.7/site-packages/amqp/channel.py:_do_close | |
Closed channel #1 | |
2014-07-07 16:31:34,996 8949 139757228312320 ./test_oslo.py:test | |
sent reply | |
2014-07-07 16:31:44,001 8949 139757120747264 /usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/impl_rabbit.py:_error_callback | |
Timed out waiting for RPC response: timed out | |
Exception in thread Thread-1: | |
Traceback (most recent call last): | |
File "/usr/lib64/python2.7/threading.py", line 810, in __bootstrap_inner | |
self.run() | |
File "/usr/lib64/python2.7/threading.py", line 763, in run | |
self.__target(*self.__args, **self.__kwargs) | |
File "./test_oslo.py", line 44, in send_main | |
timeout=timeout) | |
File "/usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/amqpdriver.py", line 412, in send | |
return self._send(target, ctxt, message, wait_for_reply, timeout) | |
File "/usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/amqpdriver.py", line 403, in _send | |
result = self._waiter.wait(msg_id, timeout) | |
File "/usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/amqpdriver.py", line 267, in wait | |
reply, ending = self._poll_connection(msg_id, timeout) | |
File "/usr/lib64/python2.7/site-packages/oslo/messaging/_drivers/amqpdriver.py", line 217, in _poll_connection | |
% msg_id) | |
MessagingTimeout: Timed out waiting for a reply to message ID 289ca319feb34fbc9f6da8e756a4185a |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment