Module Expr Str Import alias Assign NameStore Str FunctionDef arguments args defaults body Expr Str With Call AttributeLoad NameLoad attr NameStore body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword Str keyword NameLoad Expr Call AttributeLoad NameLoad attr keyword Str keyword NameLoad keyword Str keyword Call AttributeLoad NameLoad attr keyword Str Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Print Str NameLoad Expr Call AttributeLoad NameLoad attr Str keyword AttributeLoad NameLoad attr keyword Str Expr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Print Str decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Print Str NameLoad Print Str Expr Call AttributeLoad NameLoad attr decorator_list If CompareEq NameLoad Str body Expr Call NameLoad
N/A N/A 
This example demonstrates RabbitMQ's "Direct reply-to" usage via
`pika.BlockingConnection`. See https://www.rabbitmq.com/direct-reply-to.html
for more info about this feature.
 N/A pika N/A SERVER_QUEUE rpc.server.queue main N/A N/A N/A N/A N/A  Here, Client sends "Marco" to RPC Server, and RPC Server replies with
    "Polo".

    NOTE Normally, the server would be running separately from the client, but
    in this very simple example both are running in the same thread and sharing
    connection and channel.

     N/A N/A N/A pika BlockingConnection conn N/A N/A channel N/A N/A conn channel N/A N/A N/A channel queue_declare queue SERVER_QUEUE exclusive True auto_delete True N/A N/A N/A channel basic_consume on_server_rx_rpc_request queue SERVER_QUEUE N/A N/A N/A channel basic_consume on_client_rx_reply_from_server queue amq.rabbitmq.reply-to no_ack True N/A N/A N/A channel basic_publish exchange routing_key SERVER_QUEUE body Marco properties N/A N/A pika BasicProperties reply_to amq.rabbitmq.reply-to N/A N/A N/A channel start_consuming N/A on_server_rx_rpc_request N/A N/A ch method_frame properties body N/A N/A N/A RPC Server got request: body N/A N/A N/A ch basic_publish routing_key N/A properties reply_to body Polo N/A N/A N/A ch basic_ack delivery_tag N/A method_frame delivery_tag N/A RPC Server says good bye N/A on_client_rx_reply_from_server N/A N/A ch method_frame properties body N/A N/A N/A RPC Client got reply: body N/A RPC Client says bye N/A N/A N/A ch close N/A N/A N/A __name__ __main__ N/A N/A N/A main