Module ImportFrom alias TryExcept body ImportFrom alias handlers ExceptHandler type NameLoad body ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr BoolOpOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad body If CompareIsNot NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad If CompareIsNot NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Slice Num Assign NameStore AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr BoolOpOr AttributeLoad NameLoad attr Dict Assign AttributeStore NameLoad attr Call NameLoad ListComp TupleLoad Call AttributeLoad Call AttributeLoad NameLoad attr Str attr NameLoad comprehension TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr TryExcept body Expr Call NameLoad NameLoad keyword NameLoad keyword Call NameLoad AttributeLoad NameLoad attr NameLoad keyword Call NameLoad AttributeLoad NameLoad attr keyword NameLoad keyword AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad keyword Num Call NameLoad AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad If NameLoad body Expr Call NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Num Call NameLoad AttributeLoad NameLoad attr keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad ListLoad kwarg body Assert AttributeLoad NameLoad attr Assign NameStore BoolOpOr NameLoad AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad body Assert AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword Dict Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg kwarg body Pass decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad For NameStore Call NameLoad AttributeLoad NameLoad attr body Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword Call NameLoad AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad If CompareEq Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr Call NameLoad AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assert CompareIsNot AttributeLoad NameLoad attr NameLoad Return Call NameLoad AttributeLoad NameLoad attr decorator_list decorator_list
N/A __future__ absolute_import N/A N/A urlparse urlparse N/A N/A N/A ImportError N/A urllib.parse urlparse functools partial itertools cycle datetime timedelta N/A pika N/A logging pika.adapters.tornado_connection TornadoConnection pika.exceptions AMQPConnectionError tornado ioloop Connection N/A object N/A N/A content_type application/x-python-serialize __init__ N/A N/A self io_loop N/A None N/A N/A N/A self channel None N/A N/A self connection None N/A N/A self url None N/A N/A self io_loop N/A io_loop N/A N/A N/A ioloop IOLoop instance N/A connect N/A N/A self url options callback N/A None None None N/A N/A N/A url None N/A N/A N/A self url url N/A N/A options None N/A N/A N/A self options options N/A purl N/A urlparse N/A self url N/A credentials N/A N/A pika PlainCredentials N/A purl username N/A purl password N/A virtual_host N/A N/A purl path N/A 1 N/A host N/A purl hostname N/A port N/A purl port N/A N/A self options N/A N/A self options N/A N/A N/A self options N/A dict N/A N/A N/A N/A N/A N/A k lstrip DEFAULT_ lower v N/A N/A k v N/A N/A N/A self options items N/A N/A N/A N/A self options update host host port port virtual_host virtual_host credentials credentials N/A params N/A N/A pika ConnectionParameters N/A self options N/A N/A N/A N/A TornadoConnection params stop_ioloop_on_close False on_open_callback N/A partial N/A self on_connect callback on_close_callback N/A partial N/A self on_closed callback callback custom_ioloop N/A self io_loop N/A N/A N/A AMQPConnectionError N/A N/A N/A N/A logging info Retrying to connect in 2 seconds N/A N/A N/A N/A self io_loop add_timeout N/A timedelta seconds 2 N/A partial N/A self connect url url options options callback callback N/A on_connect N/A N/A self callback connection N/A N/A N/A N/A self connection connection N/A N/A N/A N/A self connection channel N/A partial N/A self on_channel_open callback N/A on_channel_open N/A N/A self callback channel N/A N/A N/A N/A self channel channel N/A callback N/A N/A N/A callback N/A on_exchange_declare N/A N/A self frame N/A N/A N/A N/A on_basic_cancel N/A N/A self frame N/A N/A N/A N/A N/A N/A self connection close N/A on_closed N/A N/A self connection reply_code reply_text callback N/A None N/A N/A This method is invoked by pika when the connection to RabbitMQ is
        closed unexpectedly. Since it is unexpected, we will reconnect to
        RabbitMQ if it disconnects.

        :param pika.connection.Connection connection: The closed connection obj
        :param int reply_code: The server provided reply_code if given
        :param str reply_text: The server provided reply_text if given

         N/A N/A self _channel None N/A N/A N/A logging warning Connection closed, reopening in 5 seconds: (%s) %s reply_code reply_text N/A N/A N/A connection add_timeout 5 N/A partial N/A self connect callback callback N/A publish N/A N/A self body exchange routing_key mandatory immediate content_type content_encoding serializer headers compression retry retry_policy declare N/A None None False False None None None None None False None N/A properties N/A N/A N/A self channel N/A content_type N/A content_type N/A self content_type N/A properties N/A N/A pika BasicProperties content_type content_type N/A N/A N/A N/A self channel basic_publish exchange exchange routing_key routing_key body body properties properties mandatory mandatory immediate immediate N/A consume N/A N/A self queue callback x_expires persistent nowait N/A None True True N/A N/A N/A self channel N/A N/A N/A N/A self channel queue_declare N/A self on_queue_declared queue queue exclusive False auto_delete True nowait nowait durable persistent arguments N/A x-expires x_expires N/A N/A N/A N/A self channel basic_consume callback queue no_ack True N/A on_queue_declared N/A N/A self N/A args kwargs N/A N/A N/A N/A ConnectionPool N/A object N/A __init__ N/A N/A self limit io_loop N/A None N/A N/A N/A self _limit limit N/A N/A self _connections N/A N/A N/A self _connection None N/A N/A self io_loop io_loop N/A connect N/A N/A self broker_url options callback N/A None None N/A N/A N/A self _on_ready callback N/A _ N/A range N/A self _limit N/A N/A conn N/A Connection io_loop N/A self io_loop N/A N/A N/A conn connect broker_url options options callback N/A partial N/A self _on_connect conn N/A _on_connect N/A N/A self connection N/A N/A N/A N/A N/A N/A self _connections append connection N/A N/A N/A len N/A self _connections N/A self _limit N/A N/A N/A self _connection N/A cycle N/A self _connections N/A N/A self _on_ready N/A N/A N/A N/A self _on_ready N/A connection N/A N/A self N/A N/A N/A N/A N/A self _connection None N/A N/A next N/A self _connection N/A N/A