Module Import alias Import alias Import alias Import alias ImportFrom alias ImportFrom alias alias alias ImportFrom alias ImportFrom alias alias alias alias ImportFrom alias ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias alias alias Assign NameStore Num Assign NameStore Call NameLoad Str Assign NameStore Call NameLoad Str keyword NameLoad keyword NameLoad FunctionDef arguments args defaults body With Call NameLoad Str NameStore body Expr Yield NameLoad decorator_list AttributeLoad NameLoad attr ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore AttributeLoad NameLoad attr attr NameLoad Assign NameStore Str Assign AttributeStore NameLoad attr ListLoad NameLoad Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Expr Call AttributeLoad NameLoad attr NameLoad Str Str Str keyword Call NameLoad keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad body While Call NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Assert UnaryOpNot AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Str Str Str Expr Call AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad Str Assert CompareEq ListLoad Str ListComp SubscriptLoad NameLoad Index Str comprehension NameStore NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Dict NameLoad Str Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assert CompareIs NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call NameLoad Assign NameStore NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults vararg kwarg body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Return Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad decorator_list decorator_list Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad body With Call AttributeLoad NameLoad attr NameLoad Str keyword NameLoad NameStore body Assign AttributeStore NameLoad attr Call NameLoad Str Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr With Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr With Call AttributeLoad NameLoad attr NameLoad body While UnaryOpNot AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Assert AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Dict NameLoad Str Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad body With Call AttributeLoad NameLoad attr NameLoad Str keyword NameLoad NameStore body Assign AttributeStore NameLoad attr Call NameLoad Str Expr Call AttributeLoad NameLoad attr With Call AttributeLoad NameLoad attr NameLoad NameStore body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assert CompareEq AttributeLoad AttributeLoad NameLoad attr attr TupleLoad Str decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Dict NameLoad Str Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad Str NameStore body Assign AttributeStore NameLoad attr Call NameLoad Str Expr Call AttributeLoad NameLoad attr With Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call NameLoad Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr With Call AttributeLoad NameLoad attr NameLoad Str keyword NameLoad NameStore body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Str FunctionDef arguments args defaults body Assert CompareGt AttributeLoad NameLoad attr Num decorator_list Expr Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad Assign NameStore Str Assign AttributeStore NameLoad attr ListLoad NameLoad ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr decorator_list NameLoad decorator_list Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list Assign NameStore ListLoad ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list Assign NameStore Call NameLoad Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad NameLoad Index Str Expr Call AttributeLoad NameLoad attr NameLoad Str Str Str keyword Call NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Str Str Str keyword Call NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Str Str Str keyword Call NameLoad keyword NameLoad With Call AttributeLoad NameLoad attr NameLoad body While CompareLt Call NameLoad NameLoad Num body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Assert CompareEq NameLoad ListLoad Str Str Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call AttributeLoad Call NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Pass decorator_list decorator_list Expr Call AttributeLoad NameLoad attr Call NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore Call NameLoad NameLoad NameLoad If NameLoad body For NameStore NameLoad body Assert CompareNotEq SubscriptLoad NameLoad Index Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body ClassDef bases NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Return NameLoad decorator_list NameLoad decorator_list Assign NameStore Call NameLoad NameLoad NameLoad Assign NameStore Call NameLoad NameLoad NameLoad Assign NameStore Call NameLoad NameLoad NameLoad Assign NameStore Call NameLoad Str With Call AttributeLoad NameLoad attr NameLoad Str NameStore body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr With Call NameLoad Str NameLoad NameStore body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str With Call AttributeLoad NameLoad attr NameLoad NameStore body Expr Call AttributeLoad NameLoad attr Assert CompareEq Call NameLoad AttributeLoad NameLoad attr Str Assert CompareEq AttributeLoad AttributeLoad NameLoad attr attr ListLoad Call NameLoad Str NameLoad NameLoad decorator_list
N/A N/A socket N/A uuid N/A eventlet N/A pytest eventlet.event Event kombu Connection Exchange Queue kombu.exceptions TimeoutError mock ANY call Mock patch nameko.constants AMQP_URI_CONFIG_KEY nameko.messaging QueueConsumer nameko.rpc rpc RpcConsumer nameko.standalone.rpc ServiceRpcProxy nameko.testing.utils assert_stops_raising get_extension get_rabbit_connections N/A TIMEOUT 5 N/A exchange N/A Exchange spam N/A ham_queue N/A Queue ham exchange exchange auto_delete False logger N/A N/A N/A N/A N/A N/A patch nameko.messaging._log logger N/A N/A N/A logger N/A N/A pytest yield_fixture MessageHandler N/A object N/A N/A queue ham_queue __init__ N/A N/A self N/A N/A N/A N/A self handle_message_called N/A Event N/A handle_message N/A N/A self body message N/A N/A N/A N/A N/A N/A self handle_message_called send message N/A wait N/A N/A self N/A N/A N/A N/A N/A N/A self handle_message_called wait N/A N/A spawn_thread N/A N/A method protected N/A N/A N/A N/A N/A eventlet spawn method N/A test_lifecycle N/A N/A rabbit_manager rabbit_config mock_container N/A N/A N/A container mock_container N/A N/A container shared_extensions N/A N/A N/A container config rabbit_config N/A N/A container max_workers 3 N/A N/A N/A container spawn_managed_thread side_effect spawn_thread N/A content_type application/data N/A N/A container accept N/A content_type N/A queue_consumer N/A N/A N/A QueueConsumer bind container N/A handler N/A MessageHandler N/A N/A N/A queue_consumer register_provider handler N/A N/A N/A queue_consumer setup N/A N/A N/A queue_consumer start N/A N/A N/A N/A container spawn_managed_thread assert_called_once_with ANY protected True N/A vhost N/A rabbit_config N/A vhost N/A N/A N/A rabbit_manager publish vhost spam shrub properties N/A dict content_type content_type N/A message N/A N/A handler wait N/A gt N/A N/A eventlet spawn N/A queue_consumer unregister_provider handler N/A N/A N/A eventlet Timeout TIMEOUT N/A N/A N/A len N/A queue_consumer _consumers N/A N/A N/A N/A eventlet sleep N/A N/A N/A gt dead N/A N/A N/A rabbit_manager publish vhost spam ni N/A N/A N/A queue_consumer ack_message message N/A N/A N/A eventlet Timeout TIMEOUT N/A N/A N/A N/A gt wait N/A messages N/A N/A rabbit_manager get_messages vhost ham N/A N/A N/A ni N/A N/A msg N/A payload N/A msg messages N/A N/A N/A queue_consumer kill N/A test_reentrant_start_stops N/A N/A mock_container N/A N/A N/A container mock_container N/A N/A container shared_extensions N/A N/A N/A container config N/A AMQP_URI_CONFIG_KEY memory:// N/A N/A container max_workers 3 N/A N/A container spawn_managed_thread spawn_thread N/A queue_consumer N/A N/A N/A QueueConsumer bind container N/A N/A N/A queue_consumer setup N/A N/A N/A queue_consumer start N/A gt N/A queue_consumer _gt N/A N/A N/A queue_consumer start N/A N/A gt N/A queue_consumer _gt N/A N/A N/A queue_consumer kill N/A test_stop_while_starting N/A N/A rabbit_config mock_container N/A N/A N/A started N/A Event N/A container mock_container N/A N/A container shared_extensions N/A N/A N/A container config rabbit_config N/A N/A container max_workers 3 N/A N/A container spawn_managed_thread spawn_thread BrokenConnConsumer N/A QueueConsumer N/A consume N/A N/A self N/A args kwargs N/A N/A N/A N/A started send None N/A N/A N/A started reset N/A N/A N/A N/A super BrokenConnConsumer self consume args kwargs N/A N/A N/A queue_consumer N/A N/A N/A BrokenConnConsumer bind container N/A N/A N/A queue_consumer setup N/A handler N/A MessageHandler N/A N/A N/A queue_consumer register_provider handler N/A N/A N/A eventlet Timeout TIMEOUT N/A N/A N/A N/A patch object Connection connect autospec True connect N/A N/A N/A connect side_effect N/A TimeoutError test N/A gt N/A N/A eventlet spawn N/A queue_consumer start N/A N/A N/A started wait N/A N/A N/A eventlet Timeout TIMEOUT N/A N/A N/A N/A queue_consumer unregister_provider handler N/A N/A N/A queue_consumer stop N/A N/A N/A eventlet Timeout TIMEOUT N/A N/A N/A N/A gt dead N/A N/A N/A N/A eventlet sleep N/A N/A N/A queue_consumer _gt dead N/A test_error_stops_consumer_thread N/A N/A mock_container N/A N/A N/A container mock_container N/A N/A container shared_extensions N/A N/A N/A container config N/A AMQP_URI_CONFIG_KEY memory:// N/A N/A container max_workers 3 N/A N/A container spawn_managed_thread spawn_thread N/A queue_consumer N/A N/A N/A QueueConsumer bind container N/A N/A N/A queue_consumer setup N/A handler N/A MessageHandler N/A N/A N/A queue_consumer register_provider handler N/A N/A N/A eventlet Timeout TIMEOUT N/A N/A N/A N/A patch object Connection drain_events autospec True drain_events N/A N/A N/A drain_events side_effect N/A Exception test N/A N/A N/A queue_consumer start N/A N/A N/A pytest raises Exception exc_info N/A N/A N/A N/A N/A queue_consumer _gt wait N/A N/A N/A N/A exc_info value args N/A test N/A test_on_consume_error_kills_consumer N/A N/A mock_container N/A N/A N/A container mock_container N/A N/A container shared_extensions N/A N/A N/A container config N/A AMQP_URI_CONFIG_KEY memory:// N/A N/A container max_workers 1 N/A N/A container spawn_managed_thread spawn_thread N/A queue_consumer N/A N/A N/A QueueConsumer bind container N/A N/A N/A queue_consumer setup N/A handler N/A MessageHandler N/A N/A N/A queue_consumer register_provider handler N/A N/A N/A patch object queue_consumer on_consume_ready on_consume_ready N/A N/A N/A on_consume_ready side_effect N/A Exception err N/A N/A N/A queue_consumer start N/A N/A N/A pytest raises Exception N/A N/A N/A N/A N/A queue_consumer _gt wait N/A test_reconnect_on_socket_error N/A N/A rabbit_config mock_container N/A N/A N/A container mock_container N/A N/A container shared_extensions N/A N/A N/A container config rabbit_config N/A N/A container max_workers 1 N/A N/A container spawn_managed_thread spawn_thread N/A connection_revived N/A Mock N/A queue_consumer N/A N/A N/A QueueConsumer bind container N/A N/A N/A queue_consumer setup N/A N/A queue_consumer on_connection_revived connection_revived N/A handler N/A MessageHandler N/A N/A N/A queue_consumer register_provider handler N/A N/A N/A queue_consumer start N/A N/A N/A patch object Connection drain_events autospec True drain_events N/A N/A N/A drain_events side_effect N/A N/A socket error test-error check_reconnected N/A N/A N/A N/A N/A N/A N/A connection_revived call_count 1 N/A N/A N/A assert_stops_raising check_reconnected N/A N/A N/A queue_consumer unregister_provider handler N/A N/A N/A queue_consumer stop N/A test_prefetch_count N/A N/A rabbit_manager rabbit_config mock_container N/A N/A N/A container mock_container N/A N/A container shared_extensions N/A N/A N/A container config rabbit_config N/A N/A container max_workers 1 N/A N/A container spawn_managed_thread spawn_thread N/A content_type application/data N/A N/A container accept N/A content_type NonShared N/A QueueConsumer N/A sharing_key N/A N/A self N/A N/A N/A N/A N/A uuid uuid4 N/A property N/A N/A queue_consumer1 N/A N/A N/A NonShared bind container N/A N/A N/A queue_consumer1 setup N/A queue_consumer2 N/A N/A N/A NonShared bind container N/A N/A N/A queue_consumer2 setup N/A consumer_continue N/A Event Handler1 N/A object N/A N/A queue ham_queue handle_message N/A N/A self body message N/A N/A N/A N/A N/A consumer_continue wait N/A N/A N/A queue_consumer1 ack_message message N/A N/A N/A messages N/A Handler2 N/A object N/A N/A queue ham_queue handle_message N/A N/A self body message N/A N/A N/A N/A N/A messages append body N/A N/A N/A queue_consumer2 ack_message message N/A N/A N/A handler1 N/A Handler1 N/A handler2 N/A Handler2 N/A N/A N/A queue_consumer1 register_provider handler1 N/A N/A N/A queue_consumer2 register_provider handler2 N/A N/A N/A queue_consumer1 start N/A N/A N/A queue_consumer2 start N/A vhost N/A rabbit_config N/A vhost N/A N/A N/A rabbit_manager publish vhost spam ham properties N/A dict content_type content_type N/A N/A N/A rabbit_manager publish vhost spam eggs properties N/A dict content_type content_type N/A N/A N/A rabbit_manager publish vhost spam bacon properties N/A dict content_type content_type N/A N/A N/A eventlet Timeout TIMEOUT N/A N/A N/A N/A len messages 2 N/A N/A N/A N/A eventlet sleep N/A N/A N/A consumer_continue send None N/A N/A messages N/A eggs bacon N/A N/A N/A queue_consumer1 unregister_provider handler1 N/A N/A N/A queue_consumer2 unregister_provider handler2 N/A N/A N/A queue_consumer1 kill N/A N/A N/A queue_consumer2 kill N/A test_kill_closes_connections N/A N/A rabbit_manager rabbit_config mock_container N/A N/A N/A container mock_container N/A N/A container shared_extensions N/A N/A N/A container config rabbit_config N/A N/A container max_workers 1 N/A N/A container spawn_managed_thread spawn_thread N/A queue_consumer N/A N/A N/A QueueConsumer bind container N/A N/A N/A queue_consumer setup Handler N/A object N/A N/A queue ham_queue handle_message N/A N/A self body message N/A N/A N/A N/A N/A N/A N/A N/A queue_consumer register_provider N/A Handler N/A N/A N/A queue_consumer start N/A N/A N/A queue_consumer kill N/A vhost N/A rabbit_config N/A vhost N/A connections N/A get_rabbit_connections vhost rabbit_manager N/A connections N/A N/A connection connections N/A N/A N/A N/A connection N/A vhost vhost N/A test_greenthread_raise_in_kill N/A N/A container_factory rabbit_config logger N/A N/A Service N/A object N/A N/A name service echo N/A N/A self arg N/A N/A N/A arg N/A rpc N/A N/A container N/A container_factory Service rabbit_config N/A queue_consumer N/A get_extension container QueueConsumer N/A rpc_consumer N/A get_extension container RpcConsumer N/A exc N/A Exception error handling message N/A N/A N/A patch object rpc_consumer handle_message handle_message N/A N/A N/A handle_message side_effect exc N/A N/A N/A container start N/A N/A ServiceRpcProxy service rabbit_config service_rpc N/A N/A N/A N/A eventlet spawn N/A service_rpc echo foo N/A N/A N/A pytest raises Exception exc_info N/A N/A N/A N/A container wait N/A N/A N/A str N/A exc_info value error handling message N/A N/A N/A N/A logger warn call_args_list N/A N/A call QueueConsumer %s raised `%s` during kill queue_consumer exc N/A