Module Import alias Import alias ImportFrom alias ImportFrom alias alias Import alias ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias alias Assign NameStore Call NameLoad Assign NameStore Dict Str Num Str Str TupleLoad Str Num ListLoad Num Num Num Num Assign NameStore Dict Str Str Dict Str Str Str Str Str Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad Dict Str Str Str Str Str NameLoad FunctionDef arguments args defaults body Pass decorator_list ClassDef bases NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Expr Call NameLoad NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Call NameLoad NameLoad decorator_list Call NameLoad Str Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore SubscriptLoad NameLoad Index Str FunctionDef arguments args NameParam NameParam defaults Str body Expr Str Assign NameStore Call AttributeLoad Str attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad keyword NameLoad FunctionDef arguments args defaults body Expr Str Return Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list Return NameLoad decorator_list Return NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore NameLoad Assign SubscriptStore NameLoad Index NameLoad NameLoad Assign NameStore Call NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Str Assign NameStore SubscriptLoad NameLoad Index NameLoad With Call NameLoad Str NameLoad NameStore body Assert CompareEq Call AttributeLoad NameLoad attr NameLoad SubscriptLoad NameLoad Index Str Assert CompareEq AttributeLoad NameLoad attr Call NameLoad SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad Call NameLoad Index Num Assert CompareEq SubscriptLoad SubscriptLoad NameLoad Index Str Index Str SubscriptLoad NameLoad Index Str decorator_list Call AttributeLoad AttributeLoad NameLoad attr attr Str ListLoad Str Str FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr With Call NameLoad Str NameLoad NameStore body With Call AttributeLoad NameLoad attr NameLoad NameStore body Expr Call AttributeLoad NameLoad attr Assert CompareEq AttributeLoad AttributeLoad NameLoad attr attr Str Assert CompareEq Call AttributeLoad NameLoad attr Str Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr With Call NameLoad Str NameLoad NameStore body With Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Assert CompareEq Call AttributeLoad NameLoad attr Str Str decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore Call NameLoad ClassDef bases NameLoad body Assign NameStore Str Assign NameStore Call NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Call NameLoad NameLoad decorator_list Call NameLoad Str Str decorator_list Assign SubscriptStore NameLoad Index NameLoad NameLoad Assign NameStore Call NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Str keyword Str Assign NameStore SubscriptLoad NameLoad Index NameLoad With Call NameLoad NameLoad Str body With Call NameLoad NameLoad Str NameStore body Expr Call NameLoad NameLoad Assert CompareEq AttributeLoad NameLoad attr Call NameLoad SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad Call NameLoad Index Num Assert CompareEq SubscriptLoad SubscriptLoad NameLoad Index Str Index Str SubscriptLoad NameLoad Index Str decorator_list Call AttributeLoad AttributeLoad NameLoad attr attr Str ListLoad Str Str FunctionDef arguments args NameParam NameParam NameParam defaults body FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Return Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad decorator_list Expr Call NameLoad Str NameLoad NameLoad Str Str ClassDef bases NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Return NameLoad decorator_list NameLoad decorator_list Assign SubscriptStore NameLoad Index NameLoad Str Assign NameStore Call NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Str With Call NameLoad Str NameLoad NameStore body Assert CompareEq Call AttributeLoad NameLoad attr Str Str Assign NameStore SubscriptLoad Call NameLoad Index Num Assert CompareIn Str SubscriptLoad NameLoad Index Str Assert CompareEq SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Str decorator_list
N/A N/A json N/A uuid kombu.serialization register mock Mock call N/A pytest nameko.constants SERIALIZER_CONFIG_KEY nameko.events event_handler EventDispatcher nameko.exceptions RemoteError nameko.rpc rpc nameko.standalone.rpc ServiceRpcProxy nameko.testing.services entrypoint_hook entrypoint_waiter N/A entrypoint_called N/A Mock N/A test_data N/A hello 123 abc foobar N/A world 456 N/A 7 8 9 1.5 N/A serialized_info N/A json pickle N/A content_type content_encoding data application/json utf-8 N/A N/A json loads N/A N/A json dumps test_data N/A content_type content_encoding data application/x-python-serialize binary test_data unserializable N/A N/A N/A N/A 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 N/A entrypoint_called arg N/A arg N/A rpc broken N/A N/A self N/A N/A N/A unserializable N/A rpc event N/A N/A self evt_data N/A N/A N/A N/A entrypoint_called evt_data N/A N/A event_handler service example N/A sniffer_queue_factory N/A N/A rabbit_config rabbit_manager N/A N/A N/A  Return a function that creates message queues to 'sniff' messages
    published to exchanges.
     N/A vhost N/A rabbit_config N/A vhost make N/A N/A exchange routing_key N/A * N/A N/A  Create a uniquely named queue and bind it to an exchange so that
        it collects messages published to that exchange.

        :Parameters:
            exchange : str
                Name of the exchange to bind to
            routing_key : str
                Routing key to bind with

        :Returns:
            A function that returns all the messages received by the queue

         N/A queue_name N/A N/A sniffer_{} format N/A N/A uuid uuid4 N/A N/A N/A rabbit_manager create_queue vhost queue_name auto_delete True N/A N/A N/A rabbit_manager create_queue_binding vhost exchange queue_name routing_key routing_key get_messages N/A N/A N/A N/A N/A  Return all messages received by the sniffer queue and remove
            them from the queue.
             N/A N/A N/A rabbit_manager get_messages vhost queue_name N/A N/A get_messages N/A N/A make N/A N/A pytest fixture test_rpc_serialization N/A N/A container_factory rabbit_config sniffer_queue_factory serializer N/A N/A N/A config rabbit_config N/A N/A config N/A SERIALIZER_CONFIG_KEY serializer N/A container N/A container_factory Service config N/A N/A N/A container start N/A get_messages N/A sniffer_queue_factory nameko-rpc N/A serialized N/A serialized_info N/A serializer N/A N/A ServiceRpcProxy service rabbit_config proxy N/A N/A N/A N/A N/A proxy echo test_data N/A serialized N/A data N/A N/A N/A entrypoint_called call_args N/A call N/A serialized N/A data N/A msg N/A N/A get_messages N/A 0 N/A N/A N/A N/A msg N/A properties N/A content_type N/A serialized N/A content_type N/A N/A N/A N/A pytest mark parametrize serializer N/A json pickle test_rpc_result_serialization_error N/A N/A container_factory rabbit_config N/A N/A N/A container N/A container_factory Service rabbit_config N/A N/A N/A container start N/A N/A ServiceRpcProxy service rabbit_config proxy N/A N/A N/A N/A pytest raises RemoteError exc N/A N/A N/A N/A proxy broken N/A N/A N/A N/A exc value exc_type UnserializableValueError N/A N/A N/A N/A proxy echo foo foo N/A test_rpc_arg_serialization_error N/A N/A container_factory rabbit_config N/A N/A N/A container N/A container_factory Service rabbit_config N/A N/A N/A container start N/A N/A ServiceRpcProxy service rabbit_config proxy N/A N/A N/A N/A pytest raises Exception N/A N/A N/A N/A proxy echo unserializable N/A N/A N/A N/A proxy echo foo foo N/A test_event_serialization N/A N/A container_factory rabbit_config sniffer_queue_factory serializer N/A N/A N/A handler_called N/A Mock Service N/A object N/A N/A name srcservice N/A dispatch N/A EventDispatcher dispatch_event N/A N/A self payload N/A N/A N/A N/A N/A self dispatch eventtype payload N/A rpc handle_event N/A N/A self event_data N/A N/A N/A N/A handler_called event_data N/A N/A event_handler srcservice eventtype N/A N/A N/A rabbit_config N/A SERIALIZER_CONFIG_KEY serializer N/A container N/A container_factory Service rabbit_config N/A N/A N/A container start N/A get_messages N/A sniffer_queue_factory srcservice.events routing_key eventtype N/A serialized N/A serialized_info N/A serializer N/A N/A entrypoint_waiter container handle_event N/A N/A N/A entrypoint_hook container dispatch_event dispatch_event N/A N/A N/A dispatch_event test_data N/A N/A N/A handler_called call_args N/A call N/A serialized N/A data N/A msg N/A N/A get_messages N/A 0 N/A N/A N/A N/A msg N/A properties N/A content_type N/A serialized N/A content_type N/A N/A N/A N/A pytest mark parametrize serializer N/A json pickle test_custom_serializer N/A N/A container_factory rabbit_config sniffer_queue_factory N/A N/A encode N/A N/A value N/A N/A N/A value N/A N/A json dumps value N/A N/A N/A value upper N/A decode N/A N/A value N/A N/A N/A value N/A N/A value lower N/A N/A N/A json loads value N/A N/A N/A register upperjson encode decode application/x-upper-json utf-8 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 N/A rabbit_config N/A SERIALIZER_CONFIG_KEY upperjson N/A container N/A container_factory Service rabbit_config N/A N/A N/A container start N/A get_messages N/A sniffer_queue_factory nameko-rpc N/A N/A ServiceRpcProxy service rabbit_config proxy N/A N/A N/A N/A N/A proxy echo hello hello N/A msg N/A N/A get_messages N/A 0 N/A N/A "RESULT": "HELLO" N/A msg N/A payload N/A N/A N/A N/A msg N/A properties N/A content_type application/x-upper-json N/A